From e36d458c35860f8681b930dbad12d7eda325c898 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 14 Dec 2018 13:37:38 -0500 Subject: [PATCH] Fix Test --- .../annotation/EnableKafkaIntegrationTests.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java index 5cf5c7a3..4723366c 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java @@ -928,6 +928,14 @@ public class EnableKafkaIntegrationTests { }; } + @Bean + public KafkaListenerErrorHandler consumeMultiMethodException(MultiListenerBean listener) { + return (m, e) -> { + listener.errorLatch.countDown(); + return null; + }; + } + } static class Listener implements ConsumerSeekAware { @@ -1275,14 +1283,6 @@ public class EnableKafkaIntegrationTests { return latch2; } - @Bean - public KafkaListenerErrorHandler consumeMultiMethodException(MultiListenerBean listener) { - return (m, e) -> { - listener.errorLatch.countDown(); - return null; - }; - } - } @KafkaListener(id = "multi", topics = "annotated8", errorHandler = "consumeMultiMethodException")