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 <[email protected]> Authored: Wed Nov 30 11:27:34 2016 -0600 Committer: jbertram <[email protected]> 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");
