iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix retry test (#13267) 

Co-authored-by: Cesare <cesare.valenti@hotmail.com>
This commit is contained in:
cesarevalenti90 2023-01-09 22:16:44 +01:00 committed by GitHub
parent d2f52b059f
commit c3a0a729db
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-kafka/src/test/java/com/baeldung/spring/kafka/KafkaRetryableIntegrationTest.java
View File

@ -57,7 +57,7 @@ public class KafkaRetryableIntegrationTest {
Greeting greeting = new Greeting("test1", "test2"); Greeting greeting = new Greeting("test1", "test2");
container.start(); container.start();
template.send(TOPIC, objectMapper.writeValueAsString(greeting)); template.send(TOPIC, objectMapper.writeValueAsString(greeting));
assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue(); assertThat(latch.await(10, TimeUnit.SECONDS)).isFalse();
} }
@Test @Test
@ -78,7 +78,7 @@ public class KafkaRetryableIntegrationTest {
//this message will go on error //this message will go on error
Greeting greeting2 = new Greeting("test2", "test2"); Greeting greeting2 = new Greeting("test2", "test2");
template.send(TOPIC, objectMapper.writeValueAsString(greeting2)); template.send(TOPIC, objectMapper.writeValueAsString(greeting2));
assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue(); assertThat(latch.getCount()).isEqualTo(1);
} }
} }