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 4aa43c0 commit caf322aCopy full SHA for caf322a
src/com/rabbitmq/client/impl/ChannelN.java
@@ -171,7 +171,9 @@ public void releaseChannelNumber() {
171
172
/**
173
* Protected API - Filters the inbound command stream, processing
174
- * Basic.Deliver, Basic.Return and Channel.Close specially.
+ * Basic.Deliver, Basic.Return and Channel.Close specially. If
175
+ * we're in quiescing mode, all inbound commands are ignored,
176
+ * except for Channel.Close and Channel.CloseOk.
177
*/
178
@Override public boolean processAsync(Command command) throws IOException
179
{
0 commit comments