Repository: activemq-artemis Updated Branches: refs/heads/master 17d891858 -> 757161f3d
NO-JIRA: Trivial test fix Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/757161f3 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/757161f3 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/757161f3 Branch: refs/heads/master Commit: 757161f3d2c85ed34b538566d178090302642ca1 Parents: 17d8918 Author: Clebert Suconic <[email protected]> Authored: Tue May 2 21:16:10 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Tue May 2 21:16:10 2017 -0400 ---------------------------------------------------------------------- .../artemis/tests/integration/ra/ActiveMQMessageHandlerXATest.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/757161f3/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerXATest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerXATest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerXATest.java index 6ff82ed..db4db9b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerXATest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerXATest.java @@ -33,6 +33,7 @@ import org.apache.activemq.artemis.core.server.Queue; import org.apache.activemq.artemis.core.transaction.impl.XidImpl; import org.apache.activemq.artemis.ra.ActiveMQResourceAdapter; import org.apache.activemq.artemis.ra.inflow.ActiveMQActivationSpec; +import org.apache.activemq.artemis.tests.util.Wait; import org.apache.activemq.artemis.utils.UUIDGenerator; import org.junit.Test; @@ -148,6 +149,7 @@ public class ActiveMQMessageHandlerXATest extends ActiveMQRATestBase { assertEquals(endpoint.lastMessage.getCoreMessage().getBodyBuffer().readString(), "teststring"); Binding binding = server.getPostOffice().getBinding(MDBQUEUEPREFIXEDSIMPLE); + Wait.waitFor(() -> getMessageCount((Queue) binding.getBindable()) == 1); long messageCount = getMessageCount((Queue) binding.getBindable()); assertEquals(1, messageCount); }
