diff --git a/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java b/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java index b0beb9660322..f33a6b8e66c3 100644 --- a/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java +++ b/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java @@ -75,12 +75,17 @@ public boolean isConnected() { @Override public boolean connect() { - final InfluxDB createdClient = InfluxDBFactory.connect(configuration.getUrl(), configuration.getUser(), - configuration.getPassword()); - createdClient.setDatabase(configuration.getDatabaseName()); - createdClient.setRetentionPolicy(configuration.getRetentionPolicy()); - createdClient.enableBatch(200, 100, TimeUnit.MILLISECONDS); - this.client = createdClient; + try { + final InfluxDB createdClient = InfluxDBFactory.connect(configuration.getUrl(), configuration.getUser(), + configuration.getPassword()); + createdClient.setDatabase(configuration.getDatabaseName()); + createdClient.setRetentionPolicy(configuration.getRetentionPolicy()); + createdClient.enableBatch(200, 100, TimeUnit.MILLISECONDS); + this.client = createdClient; + } catch (InfluxException | InfluxDBException e) { + logger.debug("Connection failed", e); + return false; + } return checkConnectionStatus(); }