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/27 11:04:13 UTC
git commit: CAMEL-7673 polish the code
Repository: camel
Updated Branches:
refs/heads/master 877854777 -> 13a92cc13
CAMEL-7673 polish the code
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/13a92cc1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/13a92cc1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/13a92cc1
Branch: refs/heads/master
Commit: 13a92cc13fc8e517633dbdc8266b3d842ccf1592
Parents: 8778547
Author: Willem Jiang <wi...@gmail.com>
Authored: Wed Aug 27 17:02:36 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Wed Aug 27 17:02:36 2014 +0800
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/mqtt/MQTTProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/13a92cc1/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 7a1797b..86dad19 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(configuration.MQTT_PUBLISH_TOPIC);
+ Object topicValue = exchange.getProperty(MQTTConfiguration.MQTT_PUBLISH_TOPIC);
if (topicValue != null) {
topicName = topicValue.toString();
}