summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArnaud Cogoluègnes <acogoluegnes@gmail.com>2021-12-10 12:08:02 +0100
committerArnaud Cogoluègnes <acogoluegnes@gmail.com>2021-12-10 12:08:02 +0100
commit1bcca0745e83c4343ea6ca4f13ec0bf6bf872f72 (patch)
treee3c93892d63ab1a6f71df08d0284a2c2729feecd
parent4c397c54fa3e8d600c93ebeced6b3cc0d5b72ecf (diff)
downloadrabbitmq-server-git-1bcca0745e83c4343ea6ca4f13ec0bf6bf872f72.tar.gz
Some CI environment may need a bit more time.
-rw-r--r--deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java
index bc804b9e47..bf47ad01ee 100644
--- a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java
+++ b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java
@@ -539,9 +539,9 @@ public class FailureTest {
keepPublishing.set(false);
- assertThat(publishingLatch.await(5, TimeUnit.SECONDS)).isTrue();
+ assertThat(publishingLatch.await(10, TimeUnit.SECONDS)).isTrue();
- waitAtMost(Duration.ofSeconds(5), () -> consumed.size() >= confirmed.size());
+ waitAtMost(Duration.ofSeconds(10), () -> consumed.size() >= confirmed.size());
assertThat(generations).hasSize(2).contains(0L, 1L);
assertThat(consumed).hasSizeGreaterThanOrEqualTo(confirmed.size());