camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hekon...@apache.org
Subject [1/2] camel git commit: Improved logging.
Date Tue, 17 Mar 2015 15:39:26 GMT
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 <hekonsek@gmail.com>
Authored: Tue Mar 17 16:00:59 2015 +0100
Committer: Henryk Konsek <hekonsek@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);
             }
         });
     }


Mime
View raw message