QPIDJMS-330: have the connection desire the ANONYMOUS-RELAY capability
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/ac5aab2c Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/ac5aab2c Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/ac5aab2c Branch: refs/heads/master Commit: ac5aab2cb0db996f7726ca6be7a5b74d7adb09b1 Parents: 2f3c13c Author: Robbie Gemmell <[email protected]> Authored: Fri Sep 29 12:19:49 2017 +0100 Committer: Robbie Gemmell <[email protected]> Committed: Fri Sep 29 12:21:39 2017 +0100 ---------------------------------------------------------------------- .../qpid/jms/provider/amqp/builders/AmqpConnectionBuilder.java | 3 ++- .../test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/ac5aab2c/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpConnectionBuilder.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpConnectionBuilder.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpConnectionBuilder.java index 6ff7a6d..5eebadb 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpConnectionBuilder.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpConnectionBuilder.java @@ -16,6 +16,7 @@ */ package org.apache.qpid.jms.provider.amqp.builders; +import static org.apache.qpid.jms.provider.amqp.AmqpSupport.ANONYMOUS_RELAY; import static org.apache.qpid.jms.provider.amqp.AmqpSupport.SOLE_CONNECTION_CAPABILITY; import static org.apache.qpid.jms.provider.amqp.AmqpSupport.DELAYED_DELIVERY; @@ -117,7 +118,7 @@ public class AmqpConnectionBuilder extends AmqpResourceBuilder<AmqpConnection, A Connection connection = getParent().getProtonConnection(); connection.setHostname(hostname); connection.setContainer(resourceInfo.getClientId()); - connection.setDesiredCapabilities(new Symbol[] { SOLE_CONNECTION_CAPABILITY, DELAYED_DELIVERY }); + connection.setDesiredCapabilities(new Symbol[] { SOLE_CONNECTION_CAPABILITY, DELAYED_DELIVERY, ANONYMOUS_RELAY}); connection.setProperties(props); return connection; http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/ac5aab2c/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java index 5081667..64cb2c6 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java @@ -18,6 +18,7 @@ */ package org.apache.qpid.jms.test.testpeer; +import static org.apache.qpid.jms.provider.amqp.AmqpSupport.ANONYMOUS_RELAY; import static org.apache.qpid.jms.provider.amqp.AmqpSupport.DELAYED_DELIVERY; import static org.apache.qpid.jms.provider.amqp.AmqpSupport.DYNAMIC_NODE_LIFETIME_POLICY; import static org.apache.qpid.jms.provider.amqp.AmqpSupport.GLOBAL; @@ -142,7 +143,7 @@ public class TestAmqpPeer implements AutoCloseable private static final UnsignedByte SASL_FAIL_AUTH = UnsignedByte.valueOf((byte)1); private static final int CONNECTION_CHANNEL = 0; private static final int DEFAULT_PRODUCER_CREDIT = 100; - private static final Symbol[] DEFAULT_DESIRED_CAPABILITIES = new Symbol[] { SOLE_CONNECTION_CAPABILITY, DELAYED_DELIVERY}; + private static final Symbol[] DEFAULT_DESIRED_CAPABILITIES = new Symbol[] { SOLE_CONNECTION_CAPABILITY, DELAYED_DELIVERY, ANONYMOUS_RELAY}; private volatile AssertionError _firstAssertionError = null; private final TestAmqpPeerRunner _driverRunnable; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
