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 1e21fa8 commit 8724b82Copy full SHA for 8724b82
src/main/java/com/rabbitmq/client/impl/ChannelN.java
@@ -381,6 +381,10 @@ private void releaseChannel() {
381
Basic.Cancel m = (Basic.Cancel)method;
382
String consumerTag = m.getConsumerTag();
383
Consumer callback = _consumers.remove(consumerTag);
384
+ // Not finding any matching consumer isn't necessarily an indication of an issue anywhere.
385
+ // Sometimes there's a natural race condition between consumer management on the server and client ends.
386
+ // E.g. Channel#basicCancel called just before a basic.cancel for the same consumer tag is received.
387
+ // See https://github.com/rabbitmq/rabbitmq-java-client/issues/525
388
if (callback == null) {
389
callback = defaultConsumer;
390
}
0 commit comments