Repository: camel Updated Branches: refs/heads/master fc3d9f223 -> 3bcc9d482
Improved logging. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b5a5904a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b5a5904a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b5a5904a Branch: refs/heads/master Commit: b5a5904a4206ca26cb8690e25c2049bdee867afe Parents: fc3d9f2 Author: Henryk Konsek <hekon...@gmail.com> Authored: Tue Mar 17 16:00:59 2015 +0100 Committer: Henryk Konsek <hekon...@gmail.com> Committed: Tue Mar 17 16:00:59 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/paho/PahoConsumer.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/b5a5904a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoConsumer.java b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoConsumer.java index c4d2386..31f56e3 100644 --- a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoConsumer.java +++ b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoConsumer.java @@ -25,9 +25,13 @@ import org.apache.camel.impl.DefaultConsumer; import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; import org.eclipse.paho.client.mqttv3.MqttCallback; import org.eclipse.paho.client.mqttv3.MqttMessage; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class PahoConsumer extends DefaultConsumer { + private static final Logger LOG = LoggerFactory.getLogger(PahoConsumer.class); + public PahoConsumer(Endpoint endpoint, Processor processor) { super(endpoint, processor); } @@ -40,7 +44,7 @@ public class PahoConsumer extends DefaultConsumer { getEndpoint().getClient().setCallback(new MqttCallback() { @Override public void connectionLost(Throwable cause) { - + LOG.debug("MQTT broker connection lost:", cause); } @Override @@ -56,7 +60,7 @@ public class PahoConsumer extends DefaultConsumer { @Override public void deliveryComplete(IMqttDeliveryToken token) { - + LOG.debug("Delivery complete. Token: {}.", token); } }); }
