You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2017/09/29 11:30:08 UTC
[2/3] qpid-jms git commit: QPIDJMS-330: have the connection desire
the ANONYMOUS-RELAY capability
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 <ro...@apache.org>
Authored: Fri Sep 29 12:19:49 2017 +0100
Committer: Robbie Gemmell <ro...@apache.org>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org