You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2020/10/18 19:24:40 UTC
[qpid-broker-j] 01/02: Added close sender when closing AMQP
connection
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit f4c8ee1b88255cb109826d6e02d0f32ff645c266
Author: aw924 <da...@deutsche-boerse.com>
AuthorDate: Mon Oct 12 12:32:29 2020 +0200
Added close sender when closing AMQP connection
(cherry picked from commit 75124c53edf4acfb10577a920dcb6a9e6ea6153f)
---
.../org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
index 0814382..09c46d1 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
@@ -1197,6 +1197,9 @@ public class AMQPConnection_1_0Impl extends AbstractAMQPConnection<AMQPConnectio
default:
throw new ServerScopedRuntimeException("Unknown state: " + _connectionState);
}
+
+ getSender().close();
+
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org