Fix Netty Stress Test
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d8f4c00e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d8f4c00e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d8f4c00e Branch: refs/heads/ARTEMIS-780 Commit: d8f4c00e0ac56014821202068775d21f853b706e Parents: 4041d40 Author: Martyn Taylor <mtay...@redhat.com> Authored: Thu Dec 1 16:29:36 2016 +0000 Committer: Martyn Taylor <mtay...@redhat.com> Committed: Thu Dec 1 16:29:36 2016 +0000 ---------------------------------------------------------------------- .../tests/integration/client/JmsNettyNioStressTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/d8f4c00e/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java index a721aca..ccbc4b2 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java @@ -26,6 +26,7 @@ import java.util.HashMap; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; +import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.TransportConfiguration; import org.apache.activemq.artemis.api.core.client.ClientSession; import org.apache.activemq.artemis.api.core.client.ClientSessionFactory; @@ -36,6 +37,7 @@ import org.apache.activemq.artemis.core.config.Configuration; import org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnectorFactory; import org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants; import org.apache.activemq.artemis.core.server.ActiveMQServer; +import org.apache.activemq.artemis.core.server.RoutingType; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQDestination; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; @@ -128,8 +130,10 @@ public class JmsNettyNioStressTest extends ActiveMQTestBase { // create the 2 queues used in the test ClientSessionFactory sf = locator.createSessionFactory(transpConf); ClientSession session = sf.createTransactedSession(); - session.createQueue("queue", "queue"); - session.createQueue("queue2", "queue2"); + session.createAddress(SimpleString.toSimpleString("queue"), RoutingType.ANYCAST, false); + session.createAddress(SimpleString.toSimpleString("queue2"), RoutingType.ANYCAST, false); + session.createQueue("queue", RoutingType.ANYCAST, "queue"); + session.createQueue("queue2", RoutingType.ANYCAST, "queue2"); session.commit(); sf.close(); session.close();
