activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: ARTEMIS-789 fix ReceiveTest
Date Sat, 17 Dec 2016 01:32:55 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master f98b410a1 -> 574cf6f3d


ARTEMIS-789 fix ReceiveTest


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8c1a9314
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8c1a9314
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8c1a9314

Branch: refs/heads/master
Commit: 8c1a9314e6c84059c5a920d513e44b2e2e89f81a
Parents: f98b410
Author: Justin Bertram <jbertram@apache.org>
Authored: Fri Dec 16 13:38:48 2016 -0600
Committer: Justin Bertram <jbertram@apache.org>
Committed: Fri Dec 16 18:48:05 2016 -0600

----------------------------------------------------------------------
 .../activemq/artemis/tests/integration/client/ReceiveTest.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/8c1a9314/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ReceiveTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ReceiveTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ReceiveTest.java
index 10160f6..5be552b 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ReceiveTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ReceiveTest.java
@@ -29,6 +29,7 @@ import org.apache.activemq.artemis.api.core.client.MessageHandler;
 import org.apache.activemq.artemis.api.core.client.ServerLocator;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
 import org.apache.activemq.artemis.core.server.Queue;
+import org.apache.activemq.artemis.core.server.RoutingType;
 import org.apache.activemq.artemis.tests.integration.mqtt.imported.util.Wait;
 import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
 import org.junit.Assert;
@@ -137,7 +138,7 @@ public class ReceiveTest extends ActiveMQTestBase {
       ClientSession sendSession = cf.createSession(false, true, true);
       ClientProducer cp = sendSession.createProducer(addressA);
       ClientSession session = cf.createSession(false, true, true);
-      session.createQueue(addressA, queueA, false);
+      session.createQueue(addressA, RoutingType.ANYCAST, queueA, false);
       ClientConsumer cc = session.createConsumer(queueA);
       ClientConsumer cc2 = session.createConsumer(queueA);
       session.start();


Mime
View raw message