Reader test improvements in latestMessageId test

- Enusre that the container is started
- Increase the latch wait timeout
This commit is contained in:
Soby Chacko
2023-02-15 13:01:53 -05:00
parent 7865973101
commit 9b5f64e5d6

View File

@@ -154,11 +154,11 @@ public class DefaultPulsarReaderListenerContainerTests implements PulsarTestCont
pulsarTemplate.sendAsync("This message should not be received by the reader");
}
container.start();
assertThat(container.isRunning()).isTrue();
pulsarTemplate.sendAsync("This message should be received by the reader");
pulsarTemplate.sendAsync("This message should be received by the reader");
assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();
assertThat(latch.await(30, TimeUnit.SECONDS)).isTrue();
}
finally {
safeStopContainer(container);