Repository: camel Updated Branches: refs/heads/master 34a054426 -> 6032163a9
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2501304b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2501304b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2501304b Branch: refs/heads/master Commit: 2501304b327b7001b938a1b7ad03be2593fb53dc Parents: 34a0544 Author: Andrea Cosentino <anco...@gmail.com> Authored: Tue Jul 11 08:28:58 2017 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Tue Jul 11 08:44:38 2017 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/influxdb/InfluxDbProducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/2501304b/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 5d318a3..625a1cb 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 @@ -81,8 +81,8 @@ public class InfluxDbProducer extends DefaultProducer { LOG.debug("Writing point {}", p.lineProtocol()); if (!connection.databaseExists(dataBaseName)) { - LOG.debug("Database {} doesn't exist. Creating it...", dataBaseName); - connection.createDatabase(dataBaseName); + LOG.debug("Database {} doesn't exist. Creating it...", dataBaseName); + connection.createDatabase(dataBaseName); } connection.write(dataBaseName, retentionPolicy, p); } catch (Exception ex) {
