//1. 手动创建，需在RabbitMQ中手动创建myQueue1 队列，否则报错 @RabbitListener(queues = “myQueue1”) public void process1(String message){ log.info(“MqReceiver1: {}”, message); }
//2. 自动创建队列 @RabbitListener(queuesToDeclare = @Queue(“myQueue2”)) public void process2(String message){ log.info(“MqReceiver2: {}”, message);
}
//3. 自动创建队列，Exchange 与 Queue绑定 @RabbitListener(bindings = @QueueBinding( value = @Queue(“myQueue3”), exchange = @Exchange(“testExChange”) )) public void process3(String message){ log.info(“MqReceiver3: {}”, message); }
 1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，会注明原创字样,如未注明都非原创，如有侵权请联系删除！；3.作者投稿可能会经我们编辑修改或补充；4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |
标签： #rabbitmq创建队列 #1 #myQueue1public #void #process1String
