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 <willem.ji...@gmail.com> Authored: Wed Aug 27 17:02:36 2014 +0800 Committer: Willem Jiang <willem.ji...@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(); }
