rabbit_stream_SUITE: Increase some timeouts

Author: dumbbell

deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java

@@ -221,6 +221,7 @@ void noLostConfirmedMessagesWhenLeaderGoesAway() throws Exception {
                 () -> {
                   connected.set(false);
 
+                  try { Thread.sleep(2000); } catch (Exception e) {}
                   Client locator =
                       cf.get(new Client.ClientParameters().port(streamPortNode2()));
                   // wait until there's a new leader
@@ -467,6 +468,7 @@ void consumerReattachesToOtherReplicaWhenReplicaGoesAway() throws Exception {
             // avoid long-running task in the IO thread
             executorService.submit(
                 () -> {
+                  try { Thread.sleep(2000); } catch (Exception e) {}
                   Client.StreamMetadata m = metadataClient.metadata(stream).get(stream);
                   int newReplicaPort = m.getReplicas().get(0).getPort();
 

deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/LeaderLocatorTest.java

@@ -28,6 +28,7 @@
 import com.rabbitmq.stream.impl.Client.Response;
 import com.rabbitmq.stream.impl.Client.StreamMetadata;
 import java.util.Collections;
+import java.time.Duration;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
@@ -57,7 +58,9 @@ void invalidLocatorShouldReturnError() {
   void clientLocalLocatorShouldMakeLeaderOnConnectedNode() {
     int[] ports = new int[] {TestUtils.streamPortNode1(), TestUtils.streamPortNode2()};
     for (int port : ports) {
-      Client client = cf.get(new Client.ClientParameters().port(port));
+      Client client = cf.get(new Client.ClientParameters()
+              .port(port)
+              .rpcTimeout(Duration.ofSeconds(30)));
       String s = UUID.randomUUID().toString();
       try {
         Response response =