是的,你可以使用channel.basicCancel(consumerTag);

編輯

例如：

String tag3 = channel.basicConsume("queue3", consumer);

channel.basicCancel(tag3)

在這里,您可以找到在5秒后取消訂閱消費者的代碼：

String tag1 = channel.basicConsume(myQueue, autoAck, consumer);

String tag2 = channel.basicConsume(myQueue2, autoAck, consumer);

executorService.execute(new Runnable() {

@Override

public void run() {

while (true) {

Delivery delivery;

try {

delivery = consumer.nextDelivery();

String message = new String(delivery.getBody());

System.out.println("Received: " + message);

} catch (Exception ex) {

Logger.getLogger(TestMng.class.getName()).log(Level.SEVERE, null, ex);

}

}

}

});

System.out.println("Consumers Ready");

try {

Thread.sleep(5000);

} catch (InterruptedException ex) {

Logger.getLogger(TestMng.class.getName()).log(Level.SEVERE, null, ex);

}

channel.basicCancel(tag2); /// here you remove only the Myqueue2

我希望它有用.

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的rabbitmq怎么停止_如何停止从选择性队列中消费消息 – RabbitMQ的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。