首页 > 编程语言 > 详细

springboot 整合ActiveMq

时间:2019-09-17 19:06:47      阅读:75      评论:0      收藏:0      [点我收藏+]

pom.xml

 <!-- 配置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);
    }
}

 

springboot 整合ActiveMq

原文:https://www.cnblogs.com/yhood/p/11536049.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!