Как использовать параллелизм в темах jms с помощью spring? Как и для очередей, мы можем установить свойства maxConcurrentConsumers на желаемое число. Но если я сделаю это для темы JMS, это приведет к одновременному использованию одного и того же сообщения, что нежелательно.
Может кто-нибудь указать мне в правильном направлении?
Ну, вы сами сказали это в комментарии, но просто для уточнения.
Внутри вашего слушателя вы по-прежнему можете создавать несколько потоков и выполнять обработку асинхронным способом. Как только вы получите свои сообщения, отправьте их асинхронному потребителю. Это довольно легко реализовать, например, с помощью какого-то исполнителя.
Я бы предпочел EventBus гуавы. Это так просто, но так легко настроить и использовать. Но это ваш выбор на самом деле.
Вы используете DefaultMessageListenerContainer неправильно. Из документов:
Обратите внимание, что динамическое масштабирование действительно имеет смысл только для очереди; для темы вы обычно придерживаетесь числа по умолчанию 1 потребитель, иначе вы получите одно и то же сообщение несколько раз на одном и том же узле.
Чтобы помочь в вашей ситуации, вы можете пересылать сообщения из темы в очередь и позволять своим потребителям потреблять из этой очереди. Если у вашего провайдера JMS есть функция переадресации, это просто изменение конфигурации вашего приложения.
