refactor(tests): drop no-op retry wrapper around TQE subscribe

subscribe() returns void immediately after kicking off the async stream,
so retryUntilSuccess cannot retry a failure — the wrapper is dead weight.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

Author: dkasimovskiy

testcontainers/src/test/java/org/testcontainers/containers/integration/tqe/TQEClusterIntegrationTest.java

@@ -38,13 +38,7 @@ void testPublishAndConsumeData(TQEVersion version) {
             // produced — avoids relying on cursor="" replay, which is unreliable while the
             // TQE 3.x broker is still settling.
             final Set<User> result = new CopyOnWriteArraySet<>();
-            Unreliables.retryUntilSuccess(
-                RETRY_TIMEOUT_SECONDS,
-                TimeUnit.SECONDS,
-                () -> {
-                  fx.consumerClient().subscribe(QUEUE_NAME, result::add);
-                  return true;
-                });
+            fx.consumerClient().subscribe(QUEUE_NAME, result::add);
 
             Unreliables.retryUntilSuccess(
                 RETRY_TIMEOUT_SECONDS,