Repository: activemq-artemis Updated Branches: refs/heads/master 339fa20f2 -> e709fc366
NO-JIRA: Fixing a 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/e709fc36 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/e709fc36 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/e709fc36 Branch: refs/heads/master Commit: e709fc366d232a1bb020e439643a27f171da59d5 Parents: 339fa20 Author: Clebert Suconic <[email protected]> Authored: Thu Jun 22 17:59:55 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu Jun 22 17:59:55 2017 -0400 ---------------------------------------------------------------------- .../activemq/artemis/tests/integration/client/RoutingTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/e709fc36/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/RoutingTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/RoutingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/RoutingTest.java index 7877a7f..6e95620 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/RoutingTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/RoutingTest.java @@ -277,7 +277,8 @@ public class RoutingTest extends ActiveMQTestBase { ClientMessage message = sendSession.createMessage(false); p.send(message); sendSession.close(); - assertEquals(1, server.locateQueue(queueA).getMessageCount() + server.locateQueue(queueB).getMessageCount()); - assertEquals(2, server.locateQueue(queueC).getMessageCount() + server.locateQueue(queueD).getMessageCount()); + + assertTrue(Wait.waitFor(() -> server.locateQueue(queueA).getMessageCount() + server.locateQueue(queueB).getMessageCount() == 1)); + assertTrue(Wait.waitFor(() -> server.locateQueue(queueC).getMessageCount() + server.locateQueue(queueD).getMessageCount() == 2)); } }
