Increate timeout for recovery in test

Author: acogoluegnes

src/test/java/com/rabbitmq/client/amqp/impl/RecoveryClusterTest.java

@@ -46,7 +46,7 @@ public class RecoveryClusterTest {
   static final BackOffDelayPolicy BACK_OFF_DELAY_POLICY = BackOffDelayPolicy.fixed(ofSeconds(1));
   static List<String> nodes;
   Environment environment;
-  Connection connection;
+  AmqpConnection connection;
   Management management;
   TestInfo testInfo;
 
@@ -60,12 +60,13 @@ void init(TestInfo info) {
     environment =
         new AmqpEnvironmentBuilder().connectionSettings().uris(URIS).environmentBuilder().build();
     this.connection =
-        environment
-            .connectionBuilder()
-            .recovery()
-            .backOffDelayPolicy(BACK_OFF_DELAY_POLICY)
-            .connectionBuilder()
-            .build();
+        (AmqpConnection)
+            environment
+                .connectionBuilder()
+                .recovery()
+                .backOffDelayPolicy(BACK_OFF_DELAY_POLICY)
+                .connectionBuilder()
+                .build();
     this.management = connection.management();
     this.testInfo = info;
   }
@@ -112,9 +113,12 @@ void clusterRestart() {
       nodes.forEach(Cli::restartNode);
       Cli.rebalance();
 
+      waitAtMost(() -> connection.state() == Resource.State.OPEN);
+
       qqNames.stream()
           .parallel()
-          .forEach(n -> waitAtMostNoException(() -> management.queueInfo(n)));
+          .forEach(
+              n -> waitAtMostNoException(TIMEOUT.multipliedBy(2), () -> management.queueInfo(n)));
       qqNames.stream()
           .parallel()
           .forEach(

src/test/java/com/rabbitmq/client/amqp/impl/TestUtils.java

@@ -91,8 +91,12 @@ interface RunnableWithException {
   }
 
   public static Duration waitAtMostNoException(RunnableWithException condition) {
+    return waitAtMostNoException(DEFAULT_CONDITION_TIMEOUT, condition);
+  }
+
+  public static Duration waitAtMostNoException(Duration timeout, RunnableWithException condition) {
     return waitAtMost(
-        DEFAULT_CONDITION_TIMEOUT,
+        timeout,
         () -> {
           try {
             condition.run();