springboot 整合ActiveMq

 <!-- 配置ActiveMQ启动器 -->
 <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
 </dependency>

//创建队列
    @Bean
    public Queue queue(){
        return new ActiveMQQueue("yhood");
    }

@Controller
@RequestMapping("queue")
public class MessageQueueController {

    //消息发送者
    @Autowired
    private JmsTemplate jmsTemplate;

    //消息队列（目的地）
    @Autowired
    private Destination destination;

    @RequestMapping("/send/{message}")
    @ResponseBody
    public String send(@PathVariable(value = "message")String message){
        jmsTemplate.convertAndSend(destination,message);
        return message;
    }

}

@Component
public class Consumer {
    @JmsListener(destination = "yhood")
    public void  reader(String text){
        System.out.println("1号接收消息:"+text);
    }
}