| commit | c4fae61eb8d89c9b20122e75691307ce82a8aaeb | [log] [tgz] |
|---|---|---|
| author | Alex Rudyy <orudyy@apache.org> | Mon Aug 19 14:22:58 2019 +0100 |
| committer | Alex Rudyy <orudyy@apache.org> | Wed Aug 21 17:34:09 2019 +0100 |
| tree | c08efb187d9aeec6470b18dfafcc92f92e91a1b5 | |
| parent | c8bbebfd146eb1e71c9e02d309e39897e8659bd8 [diff] |
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
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 @@ 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);