问题描述
请在这种情况下帮助我
假设有多个微服务消费来自rabbitmq的消息 但我想暂停一个微服务来消费消息。 1.我将如何实现这一目标?
以上基于现实生活的场景 假设我想添加新的消息供应商(用于 ex otp 发送到移动设备)并且不让它知道我以前的供应商,我想检查新供应商是否能够提供该负载。 在这种情况下,我希望不更改先前供应商端的代码且不更改队列名称 我们如何才能做到这一点? 请帮忙
解决方法
停止消费者就足以使用channel.basicCancel
:
例如:
String consumerTag = channel.basicConsume("queue3",consumer);
........ {cosumer messages}
那么你需要停止它:
channel.basicCancel(consumerTag)