camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [2/2] camel git commit: CAMEL-10688: Fixed CS and remove unuseful check related to Debug
Date Tue, 10 Jan 2017 13:52:59 GMT
CAMEL-10688: Fixed CS and remove unuseful check related to Debug


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5508b51a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5508b51a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5508b51a

Branch: refs/heads/master
Commit: 5508b51a0cc0f5f939880631324e83587e942f5b
Parents: 4ac1b23
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Tue Jan 10 14:51:23 2017 +0100
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Tue Jan 10 14:51:23 2017 +0100

----------------------------------------------------------------------
 .../apache/camel/component/influxdb/InfluxDbEndpoint.java    | 7 +++----
 .../apache/camel/component/influxdb/InfluxDbProducer.java    | 8 ++------
 2 files changed, 5 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/5508b51a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
b/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
index ee30ad3..efd6d09 100644
--- a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
+++ b/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
@@ -65,10 +65,9 @@ public class InfluxDbEndpoint extends DefaultEndpoint {
     
     @Override
     protected void doStart() throws Exception {
-    	influxDB = CamelContextHelper.mandatoryLookup(getCamelContext(), connectionBean, InfluxDB.class);
-    	LOG.debug("Resolved the connection with the name {} as {}", connectionBean, influxDB);
-        super.doStart();
-        
+        influxDB = CamelContextHelper.mandatoryLookup(getCamelContext(), connectionBean,
InfluxDB.class);
+        LOG.debug("Resolved the connection with the name {} as {}", connectionBean, influxDB);
+        super.doStart();  
     }
     
     @Override

http://git-wip-us.apache.org/repos/asf/camel/blob/5508b51a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbProducer.java
b/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbProducer.java
index 4074931..b071c13 100644
--- a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbProducer.java
+++ b/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbProducer.java
@@ -64,9 +64,7 @@ public class InfluxDbProducer extends DefaultProducer {
             Point p = exchange.getIn().getMandatoryBody(Point.class);
 
             try {
-                if (LOG.isDebugEnabled()) {
-                    LOG.debug("Writing point {}", p.lineProtocol());
-                }
+                LOG.debug("Writing point {}", p.lineProtocol());
 
                 connection.write(dataBaseName, retentionPolicy, p);
             } catch (Exception ex) {
@@ -76,9 +74,7 @@ public class InfluxDbProducer extends DefaultProducer {
             BatchPoints batchPoints = exchange.getIn().getMandatoryBody(BatchPoints.class);
 
             try {
-                if (LOG.isDebugEnabled()) {
-                    LOG.debug("Writing BatchPoints {}", batchPoints.lineProtocol());
-                }
+                LOG.debug("Writing BatchPoints {}", batchPoints.lineProtocol());
 
                 connection.write(batchPoints);
             } catch (Exception ex) {


Mime
View raw message