<dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-activemq</artifactId>
　　　　　　　<version>1.5.4.RELEASE</version>
　　　　 </dependency>

 spring:          #表示该配置直接为Spring容器负责处理 
  jms:

    pub-sub-domain: false     #配置消息的类型，如果是true则表示为topic消息，如果为false表示Queue消息

  activemq:

    user: admin     #连接用户名

    password: admin   #连接密码

    broker-url: tcp://0.0.0.0:61616         #消息组件的连接主机信息 

import org.springframework.jms.annotation.JmsListener;

import org.springframework.stereotype.Service;

@Service

public class MessageConsumerService {

    @JmsListener(destination = "mldn.msg.queue")

    public void receiveMessage(String text) {//进行消息接收处理

            System.err.println("接受消息"+text);

    }

}

public interface ImessageProducerService {

        public void sendMessage(String msg);

}

import javax.annotation.Resource;

import javax.jms.Queue;

import org.springframework.jms.core.JmsMessagingTemplate;

import org.springframework.stereotype.Service;

import cn.mldn.microboot.producer.ImessageProducerService;

@Service

public class MessageProducerServiceImpl implements ImessageProducerService {

    @Resource

    private JmsMessagingTemplate jmsMessagingTemplate;

    @Resource

    private Queue queue;

    @Override

    public void sendMessage(String msg) {

        this.jmsMessagingTemplate.convertAndSend(this.queue,msg);;

    }

}

import javax.annotation.Resource;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import org.springframework.test.context.web.WebAppConfiguration;

import cn.mldn.microboot.StartSpringBootMain;

import cn.mldn.microboot.producer.ImessageProducerService;

@SpringBootTest(classes = StartSpringBootMain.class)

@RunWith(SpringJUnit4ClassRunner.class)

@WebAppConfiguration

public class TestActiveMQ {

    @Resource

    private ImessageProducerService messageProducer;

    @Test

    public void testSend() throws Exception{

        for (int i = 0; i < 103; i++) {

            this.messageProducer.sendMessage("mldn-"+i);

        }

    }

}

import javax.jms.Queue;

import org.apache.activemq.command.ActiveMQQueue;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.jms.annotation.EnableJms;

@Configuration

@EnableJms

public class ActiveMQConfig {

    @Bean

    public Queue queue() {

        return new ActiveMQQueue("mldn.msg.queue");

    }

}