springboot与activemq的使用

<?  version="1.0" encoding="UTF-8"?><project  ns="http://maven.apache.org/POM/4.0.0"          ns:xsi="http://www.w3.org/2001/ Schema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <groupId>com.troy</groupId>    <artifactId>springbootactivemq</artifactId>    <version>1.0-SNAPSHOT</version>    <parent>        <groupId>org.spring work.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>1.5.7.RELEASE</version>    </parent>    <dependencies>        <dependency>            <groupId>org.spring work.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>            <version>1.5.7.RELEASE</version>        </dependency>        <dependency>            <groupId>org.spring work.boot</groupId>            <artifactId>spring-boot-starter-activemq</artifactId>            <version>1.5.7.RELEASE</version>        </dependency>    </dependencies></project>

server:  port: 8090spring:  activemq:    broker-url: tcp://192.168.5.10:61616    user: admin    password: admin  jms:    pub-sub-domain: true

@Configurationpublic class ActiveMqTopicConfig {    @Bean    public Topic topic(){        return new ActiveMQTopic("topic");    }}

@Configurationpublic class ActiveMqQueueConfig {    @Bean    public Queue queue(){        return new ActiveMQQueue("queue");    }}

@RestController@RequestMapping("/api")public class ActiveMqClient {    @Autowired    private JmsTemplate jmsTemplate;    @Autowired    private Topic topic;    @Autowired    private Queue queue;    @RequestMapping("/send")    public void send(){        jmsTemplate.convertAndSend(this.topic,"发送的topic数据!");        jmsTemplate.convertAndSend(this.queue,"发送的queue数据!");    }}

@RestController@RequestMapping("/api")public class ActiveMqClient {    @Autowired    private JmsTemplate jmsTemplate;    @RequestMapping("/send")    public void send(){        jmsTemplate.send("topic", new MessageCreator() {            @Override            public Message createMessage(Session session) throws JMSException {                TextMessage textMessage = session.createTextMessage();                textMessage.setText("send data");                return textMessage;            }        });    }}

@Componentpublic class ActiveMqServer {    @JmsListener(destination = "topic")    public void receiveTopic(String message) {        System.out.println("监听topic=============监听topic");        System.out.println(message);    }    @JmsListener(destination = "queue")    public void receiveQueue(String message) {        System.out.println("监听queue=============监听queue");        System.out.println(message);    }}