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