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

NO-JIRA: trivial test fix after sync changes

This commit is contained in:
Clebert Suconic 2017-05-25 17:15:34 -04:00
parent 36c0b3daf7
commit 28a60bcdf7
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/RoutingTest.java
View File

@ -29,6 +29,7 @@ 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.api.core.RoutingType; import org.apache.activemq.artemis.api.core.RoutingType;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.activemq.artemis.tests.util.Wait;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -238,8 +239,8 @@ public class RoutingTest extends ActiveMQTestBase {
message.setRoutingType(RoutingType.ANYCAST); message.setRoutingType(RoutingType.ANYCAST);
p.send(message); p.send(message);
sendSession.close(); sendSession.close();
assertEquals(1, server.locateQueue(queueA).getMessageCount() + server.locateQueue(queueB).getMessageCount()); assertTrue(Wait.waitFor(() -> server.locateQueue(queueA).getMessageCount() + server.locateQueue(queueB).getMessageCount() == 1));
assertEquals(0, server.locateQueue(queueC).getMessageCount()); assertTrue(Wait.waitFor(() -> server.locateQueue(queueC).getMessageCount() == 0));
} }
@Test @Test
@ -257,8 +258,8 @@ public class RoutingTest extends ActiveMQTestBase {
message.setRoutingType(RoutingType.MULTICAST); message.setRoutingType(RoutingType.MULTICAST);
p.send(message); p.send(message);
sendSession.close(); sendSession.close();
assertEquals(0, server.locateQueue(queueA).getMessageCount()); assertTrue(Wait.waitFor(() -> server.locateQueue(queueA).getMessageCount() == 0));
assertEquals(2, server.locateQueue(queueB).getMessageCount() + server.locateQueue(queueC).getMessageCount()); assertTrue(Wait.waitFor(() -> server.locateQueue(queueB).getMessageCount() + server.locateQueue(queueC).getMessageCount() == 2));
} }
@Test @Test