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 2019/10/02 17:10:43 UTC
[qpid-broker-j] branch 7.1.x updated: QPID-8357: [Broker-J][AMQP
1.0][Sole connection] Broker should set open property
'sole-connection-eforcement-policy' when 'close-existing' eforcement policy
is requested
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch 7.1.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/7.1.x by this push:
new 5589cd1 QPID-8357: [Broker-J][AMQP 1.0][Sole connection] Broker should set open property 'sole-connection-eforcement-policy' when 'close-existing' eforcement policy is requested
5589cd1 is described below
commit 5589cd139515fbb1e3a73911c30e3ea235c7b3a6
Author: Alex Rudyy <or...@apache.org>
AuthorDate: Mon Aug 19 14:22:58 2019 +0100
QPID-8357: [Broker-J][AMQP 1.0][Sole connection] Broker should set open property 'sole-connection-eforcement-policy' when 'close-existing' eforcement policy is requested
(cherry picked from commit c4fae61eb8d89c9b20122e75691307ce82a8aaeb)
---
.../org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java | 5 +++++
1 file changed, 5 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 bcb273d..0814382 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
@@ -1730,6 +1730,11 @@ public class AMQPConnection_1_0Impl extends AbstractAMQPConnection<AMQPConnectio
SoleConnectionDetectionPolicy.STRONG);
}
+ if (_soleConnectionEnforcementPolicy == SoleConnectionEnforcementPolicy.CLOSE_EXISTING)
+ {
+ _properties.put(SOLE_CONNECTION_ENFORCEMENT_POLICY, SoleConnectionEnforcementPolicy.CLOSE_EXISTING.getValue());
+ }
+
open.setProperties(_properties);
sendFrame(CONNECTION_CONTROL_CHANNEL, open);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org