Request a new channel after a channel is gracefully closed (#22534)

Azure · Jun 28, 2021 · f611436 · f611436
1 parent 7119e23
commit f611436
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...zure-core-amqp/src/main/java/com/azure/core/amqp/implementation/AmqpChannelProcessor.java b/...zure-core-amqp/src/main/java/com/azure/core/amqp/implementation/AmqpChannelProcessor.java
@@ -109,9 +109,10 @@ public void onNext(T amqpChannel) {
                         logger.info("namespace[{}] entityPath[{}]: Channel is disposed.",
                             fullyQualifiedNamespace, entityPath);
                     } else {
-                        logger.info("namespace[{}] entityPath[{}]: Channel is closed.",
+                        logger.info("namespace[{}] entityPath[{}]: Channel is closed. Requesting upstream. ",
                             fullyQualifiedNamespace, entityPath);
                         setAndClearChannel();
+                        requestUpstream();
                     }
                 });
         }