From a85e75daa16e4b62948704d44e8b6cbdc860871d Mon Sep 17 00:00:00 2001
From: Clebert Suconic <clebertsuconic@apache.org>
Date: Wed, 23 Aug 2017 10:48:46 -0400
Subject: [PATCH] NO-JIRA fixing intermittent test failure

There's no semantic change here, just a test fix
---
 .../cluster/distribution/MessageRedistributionTest.java   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
index 0b0fa00f46..69c03cc446 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
@@ -259,6 +259,14 @@ public class MessageRedistributionTest extends ClusterTestBase {
 
       ClientProducer producer0 = sess0.createProducer("queues.testaddress");
 
+      waitForBindings(0, "queues.testaddress", 1, 1, true);
+      waitForBindings(1, "queues.testaddress", 1, 1, true);
+      waitForBindings(2, "queues.testaddress", 1, 1, true);
+
+      waitForBindings(0, "queues.testaddress", 2, 2, false);
+      waitForBindings(1, "queues.testaddress", 2, 2, false);
+      waitForBindings(2, "queues.testaddress", 2, 2, false);
+
       final int NUMBER_OF_MESSAGES = 1000;
 
       for (int i = 0; i < 1000; i++) {