From 9330d82792132f5ef6b0ec22b622d93d57a6df08 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 31 Aug 2022 15:59:42 -0400 Subject: [PATCH] Increasing latency in consumer ack tests --- .../pulsar/core/ConsumerAcknowledgmentTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java b/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java index 867f21b1..e9b99d76 100644 --- a/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java +++ b/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java @@ -174,9 +174,9 @@ class ConsumerAcknowledgmentTests extends AbstractContainerBaseTests { Thread.sleep(1_000); // Half of the message get acknowledged, and the other half gets negatively // acknowledged. - await().atMost(Duration.ofSeconds(10)) + await().atMost(Duration.ofSeconds(30)) .untilAsserted(() -> verify(containerConsumer, times(5)).acknowledge(any(Message.class))); - await().atMost(Duration.ofSeconds(10)) + await().atMost(Duration.ofSeconds(30)) .untilAsserted(() -> verify(containerConsumer, times(5)).negativeAcknowledge(any(Message.class))); container.stop(); pulsarClient.close();