本篇介紹ActiveMQ Topics消息方式，直接碼代碼演示了：

application.properties配置加入：

＃spring.jms.pub-sub-domain=false # Specify if the default destination type is topic.
spring.jms.pub-sub-domain=true

消息生產(chǎn)者

package com.spring.boot.jms.producter;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.jms.Destination;


/**
 * Description: 消息生產(chǎn)者
 * author: 慢慢來了
 * date:  2017/3/24 14:07
 */
@Component
public class Producter {

    @Autowired
    private JmsMessagingTemplate jmsTemplate;

    public void sendMessage(Destination destination, final String message) {
        jmsTemplate.convertAndSend(destination, message);
    }


}

消息消費者，寫了二個方法監(jiān)聽msg.topics.demo隊列

package com.spring.boot.jms.consumer;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * Description:
 * author: 慢慢來了
 * date:  2017/3/24 17:31
 */
@Component
public class ConsumerTopics {

    @JmsListener(destination = "msg.topics.demo")
    public void processMessage(String content) {

        System.out.println("topics a message :" + content);

    }


    @JmsListener(destination = "msg.topics.demo")
    public void processMessage2(String content) {

        System.out.println("topics a message 2 :" + content);

    }
}

編寫單元測試

package com.spring.boot.jms;

import com.spring.boot.jms.producter.Producter;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import javax.jms.Destination;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpirngBootJmsApplicationTests {

    @Autowired
    private Producter producter;

    @Test
    public void contextLoads() {
        Destination p2pMsg = new ActiveMQQueue("msg.p2p.queue");

        producter.sendMessage(p2pMsg , "hello , this is jms msg");

    }

    @Test
    public void topics(){
        Destination topics = new ActiveMQTopic("msg.topics.demo");
        producter.sendMessage(topics , "hello , this topics msg");
    }

}

結(jié)果如下：

Paste_Image.png