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 <[email protected]> Authored: Wed May 9 20:45:12 2018 -0400 Committer: Clebert Suconic <[email protected]> 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);
