demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-10 15:11:59 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix exception handling for InfluxDB 1.x (#16234)

Browse Source 
Fixes #16233

Signed-off-by: Jacob Laursen <jacob-github@vindvejr.dk>
This commit is contained in:
Jacob Laursen 2024-01-13 13:27:29 +01:00 committed by GitHub
parent d5bbda6936
commit 3f4aac9485
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java
View File

@ -75,12 +75,17 @@ public class InfluxDB1RepositoryImpl implements InfluxDBRepository {
@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();
}