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

sync send in latestMessageId test

Browse Source 
- In order to avoid a potential race condition
  in this test, convert the asyncSend to sync.
This commit is contained in:
Soby Chacko
2023-02-15 13:18:03 -05:00
parent 9b5f64e5d6
commit e601cdcb5c
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/reader/DefaultPulsarReaderListenerContainerTests.java
View File

@@ -151,14 +151,14 @@ public class DefaultPulsarReaderListenerContainerTests implements PulsarTestCont
// The following sends will not be received by the reader as we are using the
// latest message id to start from.
for (int i = 0; i < 5; i++) {
pulsarTemplate.sendAsync("This message should not be received by the reader");
pulsarTemplate.send("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(30, TimeUnit.SECONDS)).isTrue();
assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();
}
finally {
safeStopContainer(container);