Skip to content

Commit ea89b31

Browse files
author
Steve Powell
committed
Ensure notifyOutstandingRpc() is inside synchronised block.
1 parent 4d8ba38 commit ea89b31

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

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

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -357,13 +357,13 @@ private void asyncShutdown(Command command) throws IOException {
357357
false,
358358
command,
359359
this);
360-
try {
361-
synchronized (_channelMutex) {
360+
synchronized (_channelMutex) {
361+
try {
362362
processShutdownSignal(signal, true, false);
363363
quiescingTransmit(new Channel.CloseOk());
364+
} finally {
365+
notifyOutstandingRpc(signal);
364366
}
365-
} finally {
366-
notifyOutstandingRpc(signal);
367367
}
368368
notifyListeners();
369369
}
@@ -881,4 +881,5 @@ public Channel.FlowOk getFlow() {
881881
public long getNextPublishSeqNo() {
882882
return nextPublishSeqNo;
883883
}
884-
}
884+
885+
}

0 commit comments

Comments
 (0)