Spring JMS с ActiveMQ: как асинхронно читать выборочные сообщения

Question

Я использую Spring JMS с ActiveMQ в качестве брокера и запускаю приложение на Tomcat. Я видел много примеров приема сообщений синхронно с указанным селектором сообщений, используя метод receiveSelected (..). Но я не могу найти способ динамически указывать селектор сообщений в jms: listener-container для получения сообщения асинхронно. Селектор будет известен только во время выполнения.

Единственный способ, которым я могу думать, это использовать вместо этого DefaultMessageListenerContainer и создавать новый экземпляр каждый раз, когда мне нужен новый селектор. Но я не уверен, что это правильный подход и лучшие практики в этом. Например, следует ли кэшировать listenerContainer, связанный с селектором? Когда это должно быть выключение и т. Д.?

Я был бы очень признателен, если бы кто-нибудь мог указать мне пример или набросать стратегию для решения этой ситуации.

Заранее благодарен!

Answer 1

Вы не можете изменить селектор во время работы контейнера (вы можете, но только новые потоки прослушивания будут использовать его). Вы можете остановить контейнер, изменить селектор, чтобы включить новые условия, и снова запустить контейнер.