1. 程式人生 > >SpringBoot2整合ActiveMQ實戰之釋出訂閱模式

SpringBoot2整合ActiveMQ實戰之釋出訂閱模式

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.瀏覽器訪問