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:08 UTC
[1/2] 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/camel-2.14.x 38d7dec69 -> f9245e2f5
refs/heads/camel-2.15.x e5067f2de -> bfbf24952
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/bfbf2495
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bfbf2495
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bfbf2495
Branch: refs/heads/camel-2.15.x
Commit: bfbf249520c6a8b3b4f18ea9228d70840b209935
Parents: e5067f2
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:58:54 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/bfbf2495/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 5ec0d62..1ce325b 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
@@ -89,7 +89,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());
[2/2] camel git commit: camel-kafka should create exchange with the
endpoint as reference. Thanks to Rahul Jain for the patch.
Posted by da...@apache.org.
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/f9245e2f
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f9245e2f
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f9245e2f
Branch: refs/heads/camel-2.14.x
Commit: f9245e2f5834f5627d11e848981d62b8ba7e6c6e
Parents: 38d7dec
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:05 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/f9245e2f/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 c747a7f..0a1ccc5 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
@@ -85,7 +85,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());