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/07/10 12:39:57 UTC
[1/2] camel git commit: Upgrade Influxdb client and related bundle to
version 2.7
Repository: camel
Updated Branches:
refs/heads/master f50bdb22f -> 8bba41405
Upgrade Influxdb client and related bundle to version 2.7
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/45ddde1b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/45ddde1b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/45ddde1b
Branch: refs/heads/master
Commit: 45ddde1b3f2ae11aa0612b9f3492d9351cb08ed7
Parents: f50bdb2
Author: Andrea Cosentino <an...@gmail.com>
Authored: Mon Jul 10 14:17:46 2017 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Mon Jul 10 14:17:46 2017 +0200
----------------------------------------------------------------------
parent/pom.xml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/45ddde1b/parent/pom.xml
----------------------------------------------------------------------
diff --git a/parent/pom.xml b/parent/pom.xml
index c5c68f7..fe9ee01 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -300,8 +300,8 @@
<ignite-version>1.9.0</ignite-version>
<infinispan-version>9.0.3.Final</infinispan-version>
<infinispan-spring-boot-version>1.0.0.Final</infinispan-spring-boot-version>
- <influx-java-driver-version>2.5</influx-java-driver-version>
- <influx-java-driver-bundle-version>2.5_1</influx-java-driver-bundle-version>
+ <influx-java-driver-version>2.7</influx-java-driver-version>
+ <influx-java-driver-bundle-version>2.7_1</influx-java-driver-bundle-version>
<influx-guava-version>20.0</influx-guava-version>
<irclib-bundle-version>1.10_5</irclib-bundle-version>
<irclib-version>1.10</irclib-version>
[2/2] camel git commit: CAMEL-10659: Camel-InfluxDB: Check if
Database exists and if not create it
Posted by ac...@apache.org.
CAMEL-10659: Camel-InfluxDB: Check if Database exists and if not create it
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8bba4140
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8bba4140
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8bba4140
Branch: refs/heads/master
Commit: 8bba41405f7e253f7f7592767c6bb67c201c7ba4
Parents: 45ddde1
Author: Andrea Cosentino <an...@gmail.com>
Authored: Mon Jul 10 14:38:59 2017 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Mon Jul 10 14:38:59 2017 +0200
----------------------------------------------------------------------
.../org/apache/camel/component/influxdb/InfluxDbProducer.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/8bba4140/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 c33dddc..5d318a3 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
@@ -79,7 +79,11 @@ public class InfluxDbProducer extends DefaultProducer {
try {
LOG.debug("Writing point {}", p.lineProtocol());
-
+
+ if (!connection.databaseExists(dataBaseName)) {
+ LOG.debug("Database {} doesn't exist. Creating it...", dataBaseName);
+ connection.createDatabase(dataBaseName);
+ }
connection.write(dataBaseName, retentionPolicy, p);
} catch (Exception ex) {
exchange.setException(new CamelInfluxDbException(ex));