SpringBoot2整合ActiveMQ實戰之釋出訂閱模式
阿新 • • 發佈:2019-01-12
1、預設消費者並不會消費訂閱釋出型別的訊息,這是由於springboot預設採用的是p2p模式進行訊息的監聽
在配置檔案裡面,註釋掉 #spring.jms.pub-sub-domain=true
2. //需要給topic定義獨立的JmsListenerContainer,在啟動類裡面新增
@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ConnectionFactory activeMQConnectionFactory) {
DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
bean.setPubSubDomain(true);
bean.setConnectionFactory(activeMQConnectionFactory);
return bean;
}
3. @JmsListener如果不指定獨立的containerFactory的話是隻能消費queue訊息
修改訂閱者container:containerFactory="jmsListenerContainerTopic"
4.瀏覽器訪問