Increase timeouts in test

Changes in CI made it much slower and unstable, trying to
adapt tests.

Author: acogoluegnes

src/test/java/com/rabbitmq/stream/impl/StreamEnvironmentTest.java

@@ -235,7 +235,7 @@ void growShrinkResourcesWhenProducersConsumersAreOpenedAndClosed(TestInfo info)
     int producersCount = ProducersCoordinator.MAX_PRODUCERS_PER_CLIENT * 3 + 10;
     int consumersCount = ConsumersCoordinator.MAX_SUBSCRIPTIONS_PER_CLIENT * 2 + 10;
 
-    try (Environment environment = environmentBuilder.build()) {
+    try (Environment environment = environmentBuilder.rpcTimeout(Duration.ofSeconds(20)).build()) {
       List<String> streams =
           IntStream.range(0, streamCount)
               .mapToObj(i -> streamName(info))
@@ -286,8 +286,8 @@ void growShrinkResourcesWhenProducersConsumersAreOpenedAndClosed(TestInfo info)
                         });
               });
 
-      assertThat(confirmLatch.await(10, SECONDS)).isTrue();
-      assertThat(consumeLatch.await(10, SECONDS)).isTrue();
+      latchAssert(confirmLatch).completes();
+      latchAssert(consumeLatch).completes();
 
       EnvironmentInfo environmentInfo = MonitoringTestUtils.extract(environment);
       assertThat(environmentInfo.getProducers()).hasSize(1);

src/test/java/com/rabbitmq/stream/impl/TestUtils.java

@@ -89,12 +89,12 @@ public final class TestUtils {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(TestUtils.class);
 
-  private static final Duration DEFAULT_CONDITION_TIMEOUT = Duration.ofSeconds(10);
+  private static final Duration DEFAULT_CONDITION_TIMEOUT = Duration.ofSeconds(20);
 
   private TestUtils() {}
 
   public static Duration waitAtMost(CallableBooleanSupplier condition) throws Exception {
-    return waitAtMost(10, condition, null);
+    return waitAtMost(DEFAULT_CONDITION_TIMEOUT, condition, null);
   }
 
   public static Duration waitAtMost(CallableBooleanSupplier condition, Supplier<String> message)
@@ -841,7 +841,7 @@ private BrokerVersionAtLeast311Condition() {
 
   static class CountDownLatchAssert implements AssertDelegateTarget {
 
-    private static final Duration TIMEOUT = Duration.ofSeconds(10);
+    private static final Duration TIMEOUT = DEFAULT_CONDITION_TIMEOUT;
 
     private final CountDownLatch latch;
 

src/test/java/com/rabbitmq/stream/impl/TlsTest.java

@@ -16,7 +16,6 @@
 import static com.rabbitmq.stream.impl.TestUtils.b;
 import static com.rabbitmq.stream.impl.TestUtils.latchAssert;
 import static com.rabbitmq.stream.impl.Utils.TRUST_EVERYTHING_TRUST_MANAGER;
-import static java.time.Duration.ofSeconds;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
@@ -149,7 +148,7 @@ static X509Certificate loadCertificate(String file) throws Exception {
   }
 
   @Test
-  void publishAndConsumeWithUnverifiedConnection() throws Exception {
+  void publishAndConsumeWithUnverifiedConnection() {
     int publishCount = 1_000_000;
 
     CountDownLatch consumedLatch = new CountDownLatch(publishCount);
@@ -196,8 +195,8 @@ void publishAndConsumeWithUnverifiedConnection() throws Exception {
             })
         .start();
 
-    latchAssert(confirmedLatch).completes(ofSeconds(20));
-    latchAssert(consumedLatch).completes(ofSeconds(20));
+    latchAssert(confirmedLatch).completes();
+    latchAssert(consumedLatch).completes();
     client.unsubscribe(b(1));
   }
 

src/test/java/com/rabbitmq/stream/perf/StreamPerfTestTest.java

@@ -137,7 +137,7 @@ void tearDownTest() {
 
   private void waitRunEnds(int expectedExitCode) throws Exception {
     waitAtMost(
-        20,
+        Duration.ofSeconds(30),
         () -> exitCode.get() == expectedExitCode,
         () -> "Expected " + expectedExitCode + " exit code, got " + exitCode.get());
   }
@@ -544,7 +544,12 @@ private HttpResponse(int responseCode, String body) {
 
   static class ArgumentsBuilder {
 
-    private final Map<String, String> arguments = new HashMap<>();
+    private final Map<String, String> arguments =
+        new HashMap<String, String>() {
+          {
+            put("rpc-timeout", "20");
+          }
+        };
 
     ArgumentsBuilder uris(String url) {
       arguments.put("uris", url);