Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #936

This commit is contained in:
Clebert Suconic 2016-12-16 20:32:48 -05:00
parent f98b410a1d 8c1a9314e6
commit 574cf6f3d8
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ReceiveTest.java
View File

@ -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.api.core.client.ServerLocator;
import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.Queue; 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.integration.mqtt.imported.util.Wait;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.junit.Assert; import org.junit.Assert;
@ -137,7 +138,7 @@ public class ReceiveTest extends ActiveMQTestBase {
ClientSession sendSession = cf.createSession(false, true, true); ClientSession sendSession = cf.createSession(false, true, true);
ClientProducer cp = sendSession.createProducer(addressA); ClientProducer cp = sendSession.createProducer(addressA);
ClientSession session = cf.createSession(false, true, true); 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 cc = session.createConsumer(queueA);
ClientConsumer cc2 = session.createConsumer(queueA); ClientConsumer cc2 = session.createConsumer(queueA);
session.start(); session.start();