diff --git a/pom.xml b/pom.xml
index 9e7bd20..ba10b72 100644
--- a/pom.xml
+++ b/pom.xml
@@ -18,6 +18,18 @@
DataPublishing
+
+
+
+ org.gcube.distribution
+ gcube-bom
+ LATEST
+ pom
+ import
+
+
+
+
scm:https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-publishing/${project.artifactId}
scm:https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-publishing/${project.artifactId}
@@ -28,13 +40,12 @@
org.gcube.data.publishing
document-store-lib
- [2.0.0-SNAPSHOT, 3.0.0-SNAPSHOT)
org.slf4j
slf4j-api
- 1.7.5
+
com.couchbase.client
java-client
diff --git a/src/main/java/org/gcube/documentstore/persistence/PersistenceCouchBase.java b/src/main/java/org/gcube/documentstore/persistence/PersistenceCouchBase.java
index 7160b3c..ada6112 100644
--- a/src/main/java/org/gcube/documentstore/persistence/PersistenceCouchBase.java
+++ b/src/main/java/org/gcube/documentstore/persistence/PersistenceCouchBase.java
@@ -198,8 +198,13 @@ public class PersistenceCouchBase extends PersistenceBackend {
@Override
public void close() throws Exception {
logger.trace("PersistenceCouchBase close" );
-
}
+
+ @Override
+ public boolean isConnectionActive() throws Exception{
+ return ! Connections.connectionsMap.get(nodes).getBucketsMap().get(BUCKET_SERVICE_NAME_PROPERTY_KEY).isClosed();
+ }
+
@Override
protected void closeAndClean() throws Exception {
synchronized (Connections.connectionsMap) {