[Java] Fix shouldRejoinAfterResting test.

G-Research · Dec 17, 2024 · b066904 · b066904
1 parent 42b7a2c
commit b066904
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/aeron-system-tests/src/test/java/io/aeron/UntetheredSubscriptionTest.java b/aeron-system-tests/src/test/java/io/aeron/UntetheredSubscriptionTest.java
@@ -184,7 +184,7 @@ void shouldRejoinAfterResting(final String channel)
         srcBuffer.setMemory(0, MESSAGE_LENGTH, (byte)-1);
         final String untetheredChannel = channel + "|tether=false";
         final String publicationChannel = channel.startsWith("aeron-spy") ? channel.substring(10) : channel;
-        int untetheredPollLimit = 3;
+        boolean pollingUntethered = true;
 
         try (Subscription tetheredSub = aeron.addSubscription(channel, STREAM_ID);
             Subscription untetheredSub = aeron.addSubscription(
@@ -205,9 +205,9 @@ void shouldRejoinAfterResting(final String channel)
                     aeron.conductorAgentInvoker().invoke();
                 }
 
-                if (untetheredPollLimit > 0 && untetheredSub.poll(fragmentHandler, FRAGMENT_COUNT_LIMIT) > 0)
+                if (pollingUntethered && untetheredSub.poll(fragmentHandler, FRAGMENT_COUNT_LIMIT) > 0)
                 {
-                    untetheredPollLimit--;
+                    pollingUntethered = false;
                 }
 
                 tetheredSub.poll(fragmentHandler, FRAGMENT_COUNT_LIMIT);