activemq-commits mailing list archives

Repository: activemq-artemis
Updated Branches:
  refs/heads/master d2cd21a0c -> 9723eed83


NO-JIRA Fixing another test race


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9723eed8
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9723eed8
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9723eed8

Branch: refs/heads/master
Commit: 9723eed8306f89f247f3d8d3c29cd3a422f12c87
Parents: d2cd21a
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Wed May 9 20:45:12 2018 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Wed May 9 20:45:33 2018 -0400

----------------------------------------------------------------------
 .../openwire/cluster/TemporaryQueueClusterTest.java           | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9723eed8/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
index 1d5fd00..417b9f1 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
@@ -64,6 +64,13 @@ public class TemporaryQueueClusterTest extends OpenWireJMSClusteredTestBase
{
          Session session2 = conn2.createSession(false, Session.AUTO_ACKNOWLEDGE);
          Queue targetQueue2 = session2.createQueue(QUEUE_NAME);
 
+
+         this.waitForBindings(servers[0], QUEUE_NAME, true, 1, 0, 2000);
+         this.waitForBindings(servers[1], QUEUE_NAME, true, 1, 0, 2000);
+         this.waitForBindings(servers[1], QUEUE_NAME, false, 1, 0, 2000);
+         this.waitForBindings(servers[0], QUEUE_NAME, false, 1, 0, 2000);
+
+
          MessageProducer prod1 = session1.createProducer(targetQueue1);
          MessageConsumer cons2 = session2.createConsumer(targetQueue2);