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 #2890

This commit is contained in:
Clebert Suconic 2019-11-08 13:07:08 -05:00
parent 7a8234cd07 200bee1a5f
commit 2dfb4f06ec
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpMessageRoutingTest.java
View File

@ -63,8 +63,8 @@ public class AmqpMessageRoutingTest extends JMSClientTestSupport {
sendMessages("anycast://" + addressA, 1); sendMessages("anycast://" + addressA, 1);
assertEquals(1, server.locateQueue(SimpleString.toSimpleString(queueA)).getMessageCount() + server.locateQueue(SimpleString.toSimpleString(queueB)).getMessageCount()); Wait.assertEquals(1, () -> (server.locateQueue(SimpleString.toSimpleString(queueA)).getMessageCount() + server.locateQueue(SimpleString.toSimpleString(queueB)).getMessageCount()));
assertEquals(0, server.locateQueue(SimpleString.toSimpleString(queueC)).getMessageCount()); Wait.assertEquals(0, server.locateQueue(SimpleString.toSimpleString(queueC))::getMessageCount);
} }
@Test(timeout = 60000) @Test(timeout = 60000)
@ -82,8 +82,8 @@ public class AmqpMessageRoutingTest extends JMSClientTestSupport {
sendMessages(addressA, 1, RoutingType.ANYCAST); sendMessages(addressA, 1, RoutingType.ANYCAST);
assertEquals(1, server.locateQueue(SimpleString.toSimpleString(queueA)).getMessageCount() + server.locateQueue(SimpleString.toSimpleString(queueB)).getMessageCount()); Wait.assertEquals(1, () -> (server.locateQueue(SimpleString.toSimpleString(queueA)).getMessageCount() + server.locateQueue(SimpleString.toSimpleString(queueB)).getMessageCount()));
assertEquals(0, server.locateQueue(SimpleString.toSimpleString(queueC)).getMessageCount()); Wait.assertEquals(0, server.locateQueue(SimpleString.toSimpleString(queueC))::getMessageCount);
} }
@Test(timeout = 60000) @Test(timeout = 60000)
@ -120,8 +120,8 @@ public class AmqpMessageRoutingTest extends JMSClientTestSupport {
sendMessages(addressA, 1, RoutingType.MULTICAST); sendMessages(addressA, 1, RoutingType.MULTICAST);
assertEquals(0, server.locateQueue(SimpleString.toSimpleString(queueA)).getMessageCount()); Wait.assertEquals(0, server.locateQueue(SimpleString.toSimpleString(queueA))::getMessageCount);
assertEquals(2, server.locateQueue(SimpleString.toSimpleString(queueC)).getMessageCount() + server.locateQueue(SimpleString.toSimpleString(queueB)).getMessageCount()); Wait.assertEquals(2, () -> (server.locateQueue(SimpleString.toSimpleString(queueC)).getMessageCount() + server.locateQueue(SimpleString.toSimpleString(queueB)).getMessageCount()));
} }
/** /**