欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

rabitMQ

程序员文章站 2024-01-05 11:11:28
...
 @RabbitListener(queuesToDeclare = @Queue("productInfo"))

配置这个注解会在mq里面自动生成一个列队,name为 productInfo,并监听这个列队的消息,mq里面有消息时会在这里被监听到并消费,如果消费者抛异常,就会一直接收到这个消息,直到消费完这条消息

amqpTemplate.convertAndSend("productInfo","msg");

这个方法会向mq的"productInfo"列队发送消息,发送的信息一般默认处理为base64编码