Вместо использования isRegisteredWithDestination () я использую это условие «amqBroker.getRegionBroker (). GetDestinationMap (). ContainsKey (myTopic)», которое, кажется, работает. amqBroker - это компонент BrokerService.

я есть тест интеграции для моей конфигурации Spring Integration, который использует сообщения из темы JMS с длительной подпиской. Для тестирования я использу...

Соединения JMS исчерпаны с использованием WebSphere MQ

Повторная доставка сообщений JMS при исключении в прослушивателе JMS

Javadoc для

Как добавить несколько JMS MessageListners в один MessageListenerContainer для Spring Java Config

У меня был следующий код XML в моем spring-config.xml

docs.tibco.com/products/tibco-enterprise-message-service-8-3-0

риложение использует сообщения, опубликованные в теме. У меня есть 3 сервера, на которых выполняется код моего приложения. В текущей реализации сообщения рассылаются всем работающим виртуальным машинам, т. Е. Копия сообщения принимается каждым ...

Изящно остановите DefaultMessageListenerContainer, имеющий receiveTimeout = -1

Может ли кто-нибудь указать мне на способ аккуратно остановить DefaultMessageListenerContainer в Spring, который определяется с

 (и исключить junit4 dep из org.springframework.boot: spring-boot-starter-test)

Apache MQ - селектор сообщений JMS

Мне нужна помощь, чтобы получить все сообщения для определенной очереди, которая имеет определенное свойство.Проблема здесь заключается в том, что мне нужно ...

Запустите и остановите JMS Listener, используя Spring

Итак, вопрос в том, как временно остановить и запустить прослушиватель jms, созданный с помощью Spring, следующим образом:

Как смоделировать повторную доставку сообщения в сценарии сеанса JMS AUTO_ACKNOWLEDGE?

В следующем тесте я пытаюсь смоделировать следующий сценарий: Очередь сообщений запущена.Запущен потребитель, предназначенный для сбоя во время обработки сообщения.Сообщение производится.Потребитель начинает обрабатывать сообщение.Во время ...