You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/08/29 11:20:34 UTC
[2/4] git commit: CAMEL-7473 CAMEL-7673 Put the topic name into the
message header
CAMEL-7473 CAMEL-7673 Put the topic name into the message header
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/621aaa4a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/621aaa4a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/621aaa4a
Branch: refs/heads/master
Commit: 621aaa4a7239cd17ad30a85db52ec1a70874efd2
Parents: 05c75b2
Author: Willem Jiang <wi...@gmail.com>
Authored: Fri Aug 29 14:46:20 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Fri Aug 29 17:20:01 2014 +0800
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java | 2 +-
.../main/java/org/apache/camel/component/mqtt/MQTTProducer.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/621aaa4a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java b/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
index 9c8dd95..651049c 100644
--- a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
+++ b/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
@@ -85,7 +85,7 @@ public class MQTTEndpoint extends DefaultEndpoint {
if (!consumers.isEmpty()) {
Exchange exchange = createExchange();
exchange.getIn().setBody(body.toByteArray());
- exchange.setProperty(MQTTConfiguration.MQTT_SUBSCRIBE_TOPIC, topic.toString());
+ exchange.getIn().setHeader(MQTTConfiguration.MQTT_SUBSCRIBE_TOPIC, topic.toString());
for (MQTTConsumer consumer : consumers) {
consumer.processExchange(exchange);
}
http://git-wip-us.apache.org/repos/asf/camel/blob/621aaa4a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java b/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java
index 86dad19..59ff90b 100644
--- a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java
+++ b/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java
@@ -48,7 +48,7 @@ public class MQTTProducer extends DefaultAsyncProducer implements Processor {
// where should we publish to
String topicName = configuration.getPublishTopicName();
// get the topic name by using the header of MQTT_PUBLISH_TOPIC
- Object topicValue = exchange.getProperty(MQTTConfiguration.MQTT_PUBLISH_TOPIC);
+ Object topicValue = exchange.getIn().getHeader(MQTTConfiguration.MQTT_PUBLISH_TOPIC);
if (topicValue != null) {
topicName = topicValue.toString();
}