[嗨,我在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。当我停止应用程序时,我需要确保在停止应用程序之前先停止队列侦听器(停止从队列接收消息)。我不是...
如果您想停止监听器,则必须:
如果您正在使用AMQP /兔子,则可以尝试以下一种方法: