File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/test/java/com/rabbitmq/client/test/functional Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -750,9 +750,9 @@ private ConnectionFactory buildConnectionFactoryWithRecoveryEnabled(boolean disa
750750 }
751751
752752 private static void wait (CountDownLatch latch ) throws InterruptedException {
753- // Very very generous amount of time to wait, just make sure we never
754- // hang forever
755- assertTrue (latch .await (1800 , TimeUnit .SECONDS ));
753+ // we want to wait for recovery to complete for a reasonable amount of time
754+ // but still make recovery failures easy to notice in development environments
755+ assertTrue (latch .await (90 , TimeUnit .SECONDS ));
756756 }
757757
758758 private void waitForConfirms (Channel ch ) throws InterruptedException , TimeoutException {
You can’t perform that action at this time.
0 commit comments