diff options
| -rw-r--r-- | deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java | 4 |
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()); |