diff --git a/smack-integration-test/src/main/java/org/igniterealtime/smack/XmppConnectionStressTest.java b/smack-integration-test/src/main/java/org/igniterealtime/smack/XmppConnectionStressTest.java index f741c7cc2..f9d988308 100644 --- a/smack-integration-test/src/main/java/org/igniterealtime/smack/XmppConnectionStressTest.java +++ b/smack-integration-test/src/main/java/org/igniterealtime/smack/XmppConnectionStressTest.java @@ -196,9 +196,12 @@ public class XmppConnectionStressTest { for (boolean[] markers : myReceiveMarkers.values()) { if (BooleansUtils.contains(markers, false)) { + // There is at least one message we did not receive yet, therefore do not signal the + // receivedSemaphore. return; } } + // All markers set to true, this means we received all messages. receivedSemaphore.release(); }