Use test timeout

Author: acogoluegnes

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

@@ -126,6 +126,7 @@ void clusterRestart() {
       LOGGER.info("Rebalancing over.");
 
       waitAtMost(
+          TIMEOUT,
           () -> connection.state() == OPEN,
           () -> format("Test connection state is %s, expecting %s", connection.state(), OPEN));
       LOGGER.info("Test connection has recovered");