We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9e3d06c commit 9f38faaCopy full SHA for 9f38faa
src/com/rabbitmq/client/impl/ChannelN.java
@@ -341,7 +341,7 @@ public void releaseChannelNumber() {
341
return false;
342
} else if (method instanceof Basic.Cancel) {
343
Basic.Cancel m = (Basic.Cancel)method;
344
- Consumer callback = _consumers.get(m.consumerTag);
+ Consumer callback = _consumers.remove(m.consumerTag);
345
if (callback == null) {
346
callback = defaultConsumer;
347
}
0 commit comments