diff --git a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/AmqpChannelProcessor.java b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/AmqpChannelProcessor.java
index e8dac4df57b4..0751e3ef728f 100644
--- a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/AmqpChannelProcessor.java
+++ b/sdk/core/azure-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();
                     }
                 });
         }