Skip to content

Commit 4d8ba38

Browse files
author
Steve Powell
committed
Delay notifyOutstandingRpc() until after responding to channel.close errors.
1 parent 63d7a15 commit 4d8ba38

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

src/com/rabbitmq/client/impl/ChannelN.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -357,9 +357,13 @@ private void asyncShutdown(Command command) throws IOException {
357357
false,
358358
command,
359359
this);
360-
synchronized (_channelMutex) {
361-
processShutdownSignal(signal, true, true);
362-
quiescingTransmit(new Channel.CloseOk());
360+
try {
361+
synchronized (_channelMutex) {
362+
processShutdownSignal(signal, true, false);
363+
quiescingTransmit(new Channel.CloseOk());
364+
}
365+
} finally {
366+
notifyOutstandingRpc(signal);
363367
}
364368
notifyListeners();
365369
}

0 commit comments

Comments
 (0)