We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ea4447a commit 4ed02b6Copy full SHA for 4ed02b6
src/test/java/com/rabbitmq/perf/it/ConnectionRecoveryIT.java
@@ -264,7 +264,7 @@ public void shouldRecoverWhenConnectionsAreKilledAndUsingPublishingInterval(Cons
264
waitAtMost(10, () -> msgConsumed.get() >= 3 * producerConsumerCount);
265
int messageCountBeforeClosing = msgConsumed.get();
266
closeAllConnections();
267
- waitAtMost(10, () -> msgConsumed.get() >= 2 * messageCountBeforeClosing);
+ waitAtMost(20, () -> msgConsumed.get() >= 2 * messageCountBeforeClosing);
268
assertThat(testIsDone.get()).isFalse();
269
}
270
0 commit comments