You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/05/03 01:16:21 UTC
activemq-artemis git commit: NO-JIRA: Trivial test fix
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 <cl...@apache.org>
Authored: Tue May 2 21:16:10 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
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);
}