We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents a53866a + c9fed7f commit bc2aadcCopy full SHA for bc2aadc
src/com/rabbitmq/client/impl/ChannelN.java
@@ -193,8 +193,12 @@ public void releaseChannelNumber() {
193
command,
194
this);
195
synchronized (_channelMutex) {
196
- processShutdownSignal(signal, true, true);
197
- quiescingTransmit(new Channel.CloseOk());
+ try {
+ processShutdownSignal(signal, true, false);
198
+ quiescingTransmit(new Channel.CloseOk());
199
+ } finally {
200
+ notifyOutstandingRpc(signal);
201
+ }
202
}
203
notifyListeners();
204
return true;
0 commit comments