You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/01/10 13:52:59 UTC
[2/2] camel git commit: CAMEL-10688: Fixed CS and remove unuseful
check related to Debug
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 <an...@gmail.com>
Authored: Tue Jan 10 14:51:23 2017 +0100
Committer: Andrea Cosentino <an...@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) {