67,542
社区成员
发帖
与我相关
我的任务
分享rabbitmq 手动取消消费者注册报错：java.io.IOException: Unknown consumerTag
当消费者在rabbitmq服务器上注册时，会有一个consumerTag
然后通过 Channel方法的 void basicCancel(String consumerTag) throws IOException;方法取消注册时总是报java.io.IOException: Unknown consumerTag错误
然后通过 Channel方法的 void basicCancel(String consumerTag) throws IOException;方法取消注册时总是报java.io.IOException: Unknown consumerTag错误
...全文
请发表友善的回复…
发表回复
百萬馬力 2018-12-29
- 打赏
- 举报
参考这个https://github.com/streadway/amqp/issues/146#issuecomment-372885992
意思是在哪个通道(channel)上注册的消费，就得在那个通道上basicCancel。consumerTag是通道级别的，从
if (originalConsumer == null)
throw new IOException("Unknown consumerTag");
雷小涛的摸爬滚打 2017-12-20
- 打赏
- 举报
请知道的朋友不吝赐教
