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 fd07f0d commit 3017c59Copy full SHA for 3017c59
src/com/rabbitmq/client/impl/AMQConnection.java
@@ -530,7 +530,7 @@ public boolean processControlCommand(Command c)
530
Method method = c.getMethod();
531
532
if (method instanceof AMQP.Connection.Close) {
533
- if (!_brokerInitiatedShutdown) {
+ if (!isOpen()) {
534
handleConnectionClose(c);
535
} else {
536
// Already shutting down, so just send back a CloseOk.
0 commit comments