Skip to content

Commit f611436

Browse files
authored
Request a new channel after a channel is gracefully closed (Azure#22534)
1 parent 7119e23 commit f611436

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/AmqpChannelProcessor.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,9 +109,10 @@ public void onNext(T amqpChannel) {
109109
logger.info("namespace[{}] entityPath[{}]: Channel is disposed.",
110110
fullyQualifiedNamespace, entityPath);
111111
} else {
112-
logger.info("namespace[{}] entityPath[{}]: Channel is closed.",
112+
logger.info("namespace[{}] entityPath[{}]: Channel is closed. Requesting upstream. ",
113113
fullyQualifiedNamespace, entityPath);
114114
setAndClearChannel();
115+
requestUpstream();
115116
}
116117
});
117118
}

0 commit comments

Comments
 (0)