Skip to content

Commit 1fc425c

Browse files
committed
merge v1_5 into default
2 parents 551481a + e30ef1e commit 1fc425c

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,8 +193,12 @@ public void releaseChannelNumber() {
193193
command,
194194
this);
195195
synchronized (_channelMutex) {
196-
processShutdownSignal(signal, true, true);
197-
quiescingTransmit(new Channel.CloseOk());
196+
try {
197+
processShutdownSignal(signal, true, false);
198+
quiescingTransmit(new Channel.CloseOk());
199+
} finally {
200+
notifyOutstandingRpc(signal);
201+
}
198202
}
199203
notifyListeners();
200204
return true;

0 commit comments

Comments
 (0)