Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increasing latency in consumer ack tests

Browse Source
This commit is contained in:
Soby Chacko
2022-08-31 15:59:42 -04:00
parent e364dee85a
commit 9330d82792
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java
View File

@@ -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();