From 9df2ffe248af1ecf24aec740e2fce4148d2a1d4f Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Tue, 29 Aug 2017 19:04:23 -0400 Subject: [PATCH] ARTEMIS-1297 fixing intermittent failure --- .../cluster/distribution/AMQPMessageLoadBalancingTest.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java index ba4cdaf904..53a430fdd8 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java @@ -67,6 +67,13 @@ public class AMQPMessageLoadBalancingTest extends ClusterTestBase { createQueue(0, "queues.0", "queues.0", null, true, null, null, RoutingType.ANYCAST); createQueue(1, "queues.0", "queues.0", null, true, null, null, RoutingType.ANYCAST); + waitForBindings(0, "queues.0", 1, 0, true); + waitForBindings(1, "queues.0", 1, 0, true); + + waitForBindings(0, "queues.0", 1, 0, false); + waitForBindings(1, "queues.0", 1, 0, false); + + final int NUMBER_OF_MESSAGES = 100; // sending AMQP Messages.. they should be load balanced