Skip to content

Commit 73c1e55

Browse files
committed
Increase timeout
1 parent 04681f1 commit 73c1e55

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
352352
consumeSync.reset();
353353

354354
waitAtMost(
355-
ofSeconds(20),
355+
ofSeconds(60),
356356
() -> initialFollowers.contains(mgmt.queueInfo(q).leader()),
357357
() ->
358358
"Current leader is not in initial followers, initial followers "

0 commit comments

Comments
 (0)