You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2016/11/30 17:28:07 UTC
activemq-artemis git commit: Fix JMSFailoverTest
Repository: activemq-artemis
Updated Branches:
refs/heads/ARTEMIS-780 f5929486f -> 73691a503
Fix JMSFailoverTest
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/73691a50
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/73691a50
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/73691a50
Branch: refs/heads/ARTEMIS-780
Commit: 73691a503f4ebcc1768b51339fdbfda729e408eb
Parents: f592948
Author: jbertram <jb...@apache.com>
Authored: Wed Nov 30 11:27:34 2016 -0600
Committer: jbertram <jb...@apache.com>
Committed: Wed Nov 30 11:27:34 2016 -0600
----------------------------------------------------------------------
.../tests/integration/jms/cluster/JMSFailoverTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/73691a50/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/JMSFailoverTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/JMSFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/JMSFailoverTest.java
index 6e960f2..9fa9ac4 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/JMSFailoverTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/JMSFailoverTest.java
@@ -51,6 +51,7 @@ import org.apache.activemq.artemis.core.registry.JndiBindingRegistry;
import org.apache.activemq.artemis.core.remoting.impl.invm.TransportConstants;
import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.NodeManager;
+import org.apache.activemq.artemis.core.server.RoutingType;
import org.apache.activemq.artemis.core.server.impl.InVMNodeManager;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQSession;
@@ -198,7 +199,7 @@ public class JMSFailoverTest extends ActiveMQTestBase {
SimpleString jmsQueueName = new SimpleString("myqueue");
- coreSession.createQueue(jmsQueueName, jmsQueueName, null, true);
+ coreSession.createQueue(jmsQueueName, RoutingType.ANYCAST, jmsQueueName, null, true);
Queue queue = sess.createQueue("myqueue");
@@ -271,7 +272,7 @@ public class JMSFailoverTest extends ActiveMQTestBase {
SimpleString jmsQueueName = new SimpleString("myqueue");
- coreSessionLive.createQueue(jmsQueueName, jmsQueueName, null, true);
+ coreSessionLive.createQueue(jmsQueueName, RoutingType.ANYCAST, jmsQueueName, null, true);
Queue queue = sessLive.createQueue("myqueue");
@@ -377,7 +378,7 @@ public class JMSFailoverTest extends ActiveMQTestBase {
}
};
- coreSession.createQueue(QUEUE, QUEUE, true);
+ coreSession.createQueue(QUEUE, RoutingType.ANYCAST, QUEUE, true);
Queue queue = sess.createQueue("somequeue");