java如何阻止一个微服务使用MessageQueueRabbitMQ中的消息

Question

请在这个场景中帮助我

假设有多个微服务使用来自rabbitmq的消息 但我想停下来，用一个微服务来消费这条信息。 1.我将如何实现这一目标

基于现实生活的上述场景 假设我想添加新的消息供应商（用于将ex-otp发送到移动设备），并且在不让我的前一个供应商知道的情况下，我想检查新供应商是否能够交付该负载。 在这种情况下，我希望不更改以前供应商端的代码，也不更改队列名称 我们如何才能做到这一点？ 请帮忙

Answer 1

使用channel.basicCancel即可停止消费者：

例如：

String consumerTag = channel.basicConsume("queue3", consumer);
........ {cosumer messages}

那么你需要阻止它：

channel.basicCancel(consumerTag)