SpringBoot与ActiveMQ

Demo

项目结构

项目源码

package com.supremepole.d01springbootactivemq;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

import javax.jms.Queue;

@SpringBootApplication
public class D01SpringBootActivemqApplication {

    public static void main(String[] args) {
        SpringApplication.run(D01SpringBootActivemqApplication.class, args);
    }

    @Bean
    Queue queue() {
        return new ActiveMQQueue("activemq");
    }

}

package com.supremepole.d01springbootactivemq;

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.Queue;

@Component
public class JmsComponent {
    @Autowired
    JmsMessagingTemplate messagingTemplate;
    @Autowired
    Queue queue;
    public void send(Message msg) {
        messagingTemplate.convertAndSend(this.queue, msg);
    }
    @JmsListener(destination = "activemq")
    public void receive(Message msg) {
        System.out.println("receive:" + msg);
    }
}

package com.supremepole.d01springbootactivemq;

import java.io.Serializable;
import java.util.Date;

public class Message implements Serializable {
    private String content;
    private Date date;

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public Date getDate() {
        return date;
    }

    public void setDate(Date date) {
        this.date = date;
    }

    @Override
    public String toString() {
        return "Message{" +
                "content='" + content + '\'' +
                ", date=" + date +
                '}';
    }
}

server.port=8081

spring.activemq.broker-url=tcp://[server-address]:[activemq-port]
spring.activemq.packages.trust-all=true
#spring.activemq.user=admin
#spring.activemq.password=admin