如何阻止一个微服务消费消息队列中的消息-RabbitMQ

问题描述

在这种情况下帮助我

假设有多个微服务消费来自rabbitmq的消息 但我想暂停一个微服务来消费消息。 1.我将如何实现这一目标?

以上基于现实生活的场景 假设我想添加新的消息供应商(用于 ex otp 发送到移动设备)并且不让它知道我以前的供应商,我想检查新供应商是否能够提供该负载在这种情况下,我希望不更改先前供应商端的代码且不更改队列名称 我们如何才能做到这一点? 请帮忙

解决方法

停止消费者就足以使用channel.basicCancel

例如:

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

那么你需要停止它:

channel.basicCancel(consumerTag)