Skip to content

Commit 0afae4e

Browse files
Remove useless latch.
1 parent 82ecac7 commit 0afae4e

File tree

2 files changed

+0
-12
lines changed

2 files changed

+0
-12
lines changed

spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncCompletableFutureRetryTopicScenarioTests.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -866,10 +866,6 @@ static class CountDownLatchContainer {
866866

867867
CountDownLatch dltCountdownLatch6 = new CountDownLatch(DLT_COUNT6);
868868

869-
CountDownLatch customErrorHandlerCountdownLatch = new CountDownLatch(6);
870-
871-
CountDownLatch customMessageConverterCountdownLatch = new CountDownLatch(6);
872-
873869
}
874870

875871
static class MyCustomDltProcessor {
@@ -973,7 +969,6 @@ RetryTopicConfiguration testRetryTopic6(KafkaTemplate<String, String> template)
973969
KafkaListenerErrorHandler myCustomErrorHandler(
974970
CountDownLatchContainer container) {
975971
return (message, exception) -> {
976-
container.customErrorHandlerCountdownLatch.countDown();
977972
throw exception;
978973
};
979974
}
@@ -985,7 +980,6 @@ SmartMessageConverter myCustomMessageConverter(
985980

986981
@Override
987982
public Object fromMessage(Message<?> message, Class<?> targetClass, Object conversionHint) {
988-
container.customMessageConverterCountdownLatch.countDown();
989983
return super.fromMessage(message, targetClass, conversionHint);
990984
}
991985
};

spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncMonoRetryTopicScenarioTests.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -891,10 +891,6 @@ static class CountDownLatchContainer {
891891

892892
CountDownLatch dltCountdownLatch6 = new CountDownLatch(DLT_COUNT6);
893893

894-
CountDownLatch customErrorHandlerCountdownLatch = new CountDownLatch(6);
895-
896-
CountDownLatch customMessageConverterCountdownLatch = new CountDownLatch(6);
897-
898894
}
899895

900896
static class MyCustomDltProcessor {
@@ -997,7 +993,6 @@ RetryTopicConfiguration testRetryTopic6(KafkaTemplate<String, String> template)
997993
KafkaListenerErrorHandler myCustomErrorHandler(
998994
CountDownLatchContainer container) {
999995
return (message, exception) -> {
1000-
container.customErrorHandlerCountdownLatch.countDown();
1001996
throw exception;
1002997
};
1003998
}
@@ -1009,7 +1004,6 @@ SmartMessageConverter myCustomMessageConverter(
10091004

10101005
@Override
10111006
public Object fromMessage(Message<?> message, Class<?> targetClass, Object conversionHint) {
1012-
container.customMessageConverterCountdownLatch.countDown();
10131007
return super.fromMessage(message, targetClass, conversionHint);
10141008
}
10151009
};

0 commit comments

Comments
 (0)