ARTEMIS-1680 Fixing intermittent failure

This will make sure the cluster is well formed before doing assertions
This commit is contained in:
Clebert Suconic 2018-02-19 17:16:24 -05:00
parent cfb38589de
commit 132af01595
1 changed files with 2 additions and 0 deletions

View File

@ -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);