You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/06/28 10:53:44 UTC
camel git commit: camel-kafka should create exchange with the
endpoint as reference. Thanks to Rahul Jain for the patch.
Repository: camel
Updated Branches:
refs/heads/master 6dba8a95b -> 35735204a
camel-kafka should create exchange with the endpoint as reference. Thanks to Rahul Jain for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/35735204
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/35735204
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/35735204
Branch: refs/heads/master
Commit: 35735204a815cc2cd1cc108e47218f793ebea377
Parents: 6dba8a9
Author: Claus Ibsen <da...@apache.org>
Authored: Sun Jun 28 10:58:10 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sun Jun 28 10:59:38 2015 +0200
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/kafka/KafkaEndpoint.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/35735204/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
index bebe6d7..df213f3 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
@@ -84,7 +84,7 @@ public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersS
}
public Exchange createKafkaExchange(MessageAndMetadata<byte[], byte[]> mm) {
- Exchange exchange = new DefaultExchange(getCamelContext(), getExchangePattern());
+ Exchange exchange = new DefaultExchange(this, getExchangePattern());
Message message = new DefaultMessage();
message.setHeader(KafkaConstants.PARTITION, mm.partition());