Очереди и темы в одном Java-проекте

Я хочу использовать JMS-очереди и темы в моем проекте загрузки java Spring. Итак, для тем я должен использовать это в application.properties spring.jms.pub-sub-domain = true. Теперь в том же проекте я хочу получать сообщения о очередях, покупая ActiveMQ, не вижу никакого потребителя для моей очереди ... Как я могу заставить его работать? Образец моего JmsListener для сообщения отправки с ActiveMQ локального хоста: 8161Очереди и темы в одном Java-проекте

@JmsListener(destination = "FROMACTIVEMQ") 
    public void getMessageFromActiveMq(TextMessage txt){ 
     logger.info(txt); 
    }

Что я делаю неправильно? Когда я использую sendAndReceive метод из JmsTemplate все идет правильно ...

источник

2016-08-29 amkz

Вам нужны отдельные слушатели для очереди и темы. – duffymo

@duffymo У меня есть отдельные слушатели в отдельном классе atComponent, он все еще не работает ... – amkz

Просто определить два DefaultJmsListenerContainerFactory - один для очереди и один для темы - http://docs.spring.io/spring/docs/current/spring-framework-reference/html/jms.html 30.6.1 и передать его @JmsListener (containerFactory = «» ..)

источник

2016-08-30 12:46:07 Sidooh92

Исправить! Это работает! Кто-нибудь знает другие возможные варианты решения этой проблемы? – amkz

Очереди и темы в одном Java-проекте

ответ

Смежные вопросы