Мне нужно знать об обработке потребленного сообщения (потока потока) через Spring SimpleMessageListenerContainer
У меня есть следующее понимание
1) Сообщения, используемые через потоки потребителя.(вы можете определить пулы потоков-потребителей через исполнителей задач).
2) тот же поток-потребитель, который получает сообщение, обрабатывает его и блокируется до тех пор, пока не завершит выполнение метода-обработчика.
3) между тем создаются другие потребительские потоки, которые используют другие сообщения и обрабатывают их.Интервал создания этих потребительских потоков основан на настройках setStartConsumerMinInterval.
Пожалуйста, дайте мне знать, если я прав?
Следующая часть -
Я хочу отделить потреблениесообщения и обработка сообщения в разных потоках (разные пулы для потребления и обработки), как мы можем это сделать?Я пробовал таким образом, я сделал дескриптор сообщения обработчика как @Async, чтобы запустить его в разных потоках.Это правильный путь или какой-то лучший способ доступен?
Последняя часть
в моем загрузочном приложении Spring. Я публикую и использую сообщения, и я использую одну фабрику соединений (CachingConnectionFactory).Должен ли я использовать 2 фабрики соединений 1 для публикации и другие для потребления?и передать фабрику соответствующего соединения издательским и потребляющим компонентам?