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

Fix mocking for final ConsumerRecord

Browse Source 
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**
This commit is contained in:
Artem Bilan
2017-05-30 14:16:51 -04:00
parent 2393cfea8a
commit ecde553dd7
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-kafka/src/test/java/org/springframework/kafka/listener/adapter/RetryingMessageListenerAdapterTests.java
View File

@@ -46,8 +46,7 @@ public class RetryingMessageListenerAdapterTests {
context.set(c);
return null;
});
@SuppressWarnings("unchecked")
ConsumerRecord<String, String> record = mock(ConsumerRecord.class);
ConsumerRecord<String, String> 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<String, String> record = mock(ConsumerRecord.class);
ConsumerRecord<String, String> record = new ConsumerRecord<>("mockTopic", 0, 0, null, null);
Acknowledgment ack = mock(Acknowledgment.class);
adapter.onMessage(record, ack);
assertThat(context.get()).isNotNull();