小编man*_*nna的帖子

使用Java停止队列监听RabbitMQ

嗨,我在我的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"); 
}
Run Code Online (Sandbox Code Playgroud)

java message-queue rabbitmq

1
推荐指数
1
解决办法
3668
查看次数

标签 统计

java ×1

message-queue ×1

rabbitmq ×1