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.
1 parent 7c93c10 commit 8b243deCopy full SHA for 8b243de
src/com/rabbitmq/client/impl/ChannelN.java
@@ -560,10 +560,10 @@ public AMQCommand transformReply(AMQCommand command) {
560
quiescingRpc(reason, k);
561
}
562
563
- // Now that we're in quiescing state, channel.close was sent and
564
- // we wait for the reply. We ignore the result.
565
- // (It's NOT always close-ok.)
566
- notify = true;
+ // Now that we're in quiescing state, channel.close was sent and
+ // we wait for the reply. We ignore the result.
+ // (It's NOT always close-ok.)
+ notify = true;
567
k.getReply(-1);
568
} catch (TimeoutException ise) {
569
// Will never happen since we wait infinitely
0 commit comments