From ecde553dd73cafc427f873eb0f7b187e83e5bedf Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 30 May 2017 14:16:51 -0400 Subject: [PATCH] Fix mocking for `final ConsumerRecord` https://build.spring.io/browse/SK-SK11X-30/ https://build.spring.io/browse/SK-SK10X-36/ ``` org.mockito.exceptions.base.MockitoException: org.mockito.exceptions.base.MockitoException: Cannot mock/spy class org.apache.kafka.clients.consumer.ConsumerRecord Mockito cannot mock/spy following: - final classes - anonymous classes - primitive types ``` **Cherry-pick to 1.0.x** --- .../adapter/RetryingMessageListenerAdapterTests.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/adapter/RetryingMessageListenerAdapterTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/adapter/RetryingMessageListenerAdapterTests.java index ce686320..c52262f8 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/listener/adapter/RetryingMessageListenerAdapterTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/adapter/RetryingMessageListenerAdapterTests.java @@ -46,8 +46,7 @@ public class RetryingMessageListenerAdapterTests { context.set(c); return null; }); - @SuppressWarnings("unchecked") - ConsumerRecord record = mock(ConsumerRecord.class); + ConsumerRecord record = new ConsumerRecord<>("mockTopic", 0, 0, null, null); adapter.onMessage(record); assertThat(context.get()).isNotNull(); assertThat(context.get().getAttribute(RetryingMessageListenerAdapter.CONTEXT_ACKNOWLEDGMENT)).isNull(); @@ -65,8 +64,7 @@ public class RetryingMessageListenerAdapterTests { context.set(c); return null; }); - @SuppressWarnings("unchecked") - ConsumerRecord record = mock(ConsumerRecord.class); + ConsumerRecord record = new ConsumerRecord<>("mockTopic", 0, 0, null, null); Acknowledgment ack = mock(Acknowledgment.class); adapter.onMessage(record, ack); assertThat(context.get()).isNotNull();