You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ra...@apache.org on 2015/09/03 00:32:37 UTC
[2/2] camel git commit: CAMEL-8923 Use local var instead of getter
again.
CAMEL-8923 Use local var instead of getter again.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a9bad7b1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a9bad7b1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a9bad7b1
Branch: refs/heads/master
Commit: a9bad7b1a06758f5dad72e436aed8dc6d21537e5
Parents: dc9e8eb
Author: Raul Kripalani <ra...@apache.org>
Authored: Wed Sep 2 23:32:13 2015 +0100
Committer: Raul Kripalani <ra...@apache.org>
Committed: Wed Sep 2 23:32:13 2015 +0100
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/kafka/KafkaProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a9bad7b1/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
index 3bc8e78..06a0317 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
@@ -66,7 +66,7 @@ public class KafkaProducer<K, V> extends DefaultProducer {
public void process(Exchange exchange) throws CamelException {
String topic = endpoint.getTopic();
if (!endpoint.isBridgeEndpoint()) {
- topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, endpoint.getTopic(), String.class);
+ topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class);
}
if (topic == null) {
throw new CamelExchangeException("No topic key set", exchange);