使用Java停止队列监听RabbitMQ

问题描述 投票:1回答:2

[嗨,我在Java应用程序中使用RabbitMQ。当我停止应用程序时,我需要确保在停止应用程序之前先停止队列侦听器(停止从队列接收消息)。我不确定是否需要调用channel.close()channel.basicCancel(“ tag”)] >>。编写了以下代码来停止队列侦听。

if(myContext.myChannel.isOpen()){ 

  //myChannel is the one I am using to listen to queue 
  myContext.myChannel.basicCancel("OP"); 

  //myContext.myChannel.close(); 
}else{ 
   return ok("Channel is not open"); 
}

[嗨,我在Java应用程序中使用RabbitMQ。当我停止应用程序时,我需要确保在停止应用程序之前先停止队列侦听器(停止从队列接收消息)。我不是...

java rabbitmq message-queue
2个回答
5
投票

如果您想停止监听器,则必须:


0
投票

如果您正在使用AMQP /兔子,则可以尝试以下一种方法:

© www.soinside.com 2019 - 2024. All rights reserved.