You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/05/01 13:51:07 UTC
camel git commit: Fixed KafkaProducerTest test in camel-kafka
component
Repository: camel
Updated Branches:
refs/heads/camel-2.17.x 2f8592754 -> 0b12de948
Fixed KafkaProducerTest test in camel-kafka component
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0b12de94
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0b12de94
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0b12de94
Branch: refs/heads/camel-2.17.x
Commit: 0b12de94819f5839a2f25fd2de9ef740a7abfa45
Parents: 2f85927
Author: Andrea Cosentino <an...@gmail.com>
Authored: Sun May 1 13:49:11 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Sun May 1 13:49:11 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/kafka/KafkaProducerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/0b12de94/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
index 8e94320..06deedc 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
@@ -53,7 +53,7 @@ public class KafkaProducerTest {
Future future = Mockito.mock(Future.class);
Mockito.when(future.get()).thenReturn(rm);
org.apache.kafka.clients.producer.KafkaProducer kp = Mockito.mock(org.apache.kafka.clients.producer.KafkaProducer.class);
- Mockito.when(kp.send(Mockito.any())).thenReturn(future);
+ Mockito.when(kp.send(Mockito.any(ProducerRecord.class))).thenReturn(future);
producer.setKafkaProducer(kp);
}