activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject activemq-artemis git commit: NO-JIRA: Fixing a test
Date Thu, 22 Jun 2017 22:01:49 GMT
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 <clebertsuconic@apache.org>
Authored: Thu Jun 22 17:59:55 2017 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
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));
    }
 }


Mime
View raw message