Repository: activemq-artemis Updated Branches: refs/heads/master 0ac9dbd57 -> f5456e760
ARTEMIS-737 fixing 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/f5456e76 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/f5456e76 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/f5456e76 Branch: refs/heads/master Commit: f5456e760a6bc3f15e9797b6fd08318223e17b09 Parents: 0ac9dbd Author: Clebert Suconic <[email protected]> Authored: Tue Sep 27 09:56:10 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Tue Sep 27 09:57:52 2016 -0400 ---------------------------------------------------------------------- .../artemis/junit/MultipleEmbeddedJMSResourcesTest.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/f5456e76/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java ---------------------------------------------------------------------- diff --git a/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java b/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java index e2b8416..084b7a2 100644 --- a/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java +++ b/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java @@ -49,6 +49,12 @@ public class MultipleEmbeddedJMSResourcesTest { Message pushedTwo = jmsServerTwo.pushMessage(TEST_QUEUE_TWO, TEST_BODY); assertNotNull(String.format(ASSERT_PUSHED_FORMAT, TEST_QUEUE_TWO), pushedTwo); + Wait.waitFor(new Wait.Condition() { + @Override + public boolean isSatisfied() throws Exception { + return jmsServerOne.getMessageCount(TEST_QUEUE_ONE) == 1 && jmsServerTwo.getMessageCount(TEST_QUEUE_TWO) == 1; + } + }, 5000, 100); assertEquals(String.format(ASSERT_COUNT_FORMAT, TEST_QUEUE_ONE), 1, jmsServerOne.getMessageCount(TEST_QUEUE_ONE)); assertEquals(String.format(ASSERT_COUNT_FORMAT, TEST_QUEUE_TWO), 1, jmsServerTwo.getMessageCount(TEST_QUEUE_TWO)); }
