diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MqttClusterWildcardTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MqttClusterWildcardTest.java
index 105e7d72cb..b9185b2f23 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MqttClusterWildcardTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MqttClusterWildcardTest.java
@@ -169,6 +169,8 @@ public class MqttClusterWildcardTest extends ClusterTestBase {
 
          waitForBindings(1, TOPIC, 1, 1, false);
          waitForBindings(1, TOPIC, 1, 1, true);
+         waitForBindings(0, TOPIC, 1, 1, true);
+
 
          connection1.publish("test/1/some/la", payload1.getBytes(), QoS.AT_LEAST_ONCE, false);
          connection1.publish("test/1/some/la", payload2.getBytes(), QoS.AT_MOST_ONCE, false);