diff --git a/src/main/java/org/gcube/datatransfer/resolver/services/StorageIDResolver.java b/src/main/java/org/gcube/datatransfer/resolver/services/StorageIDResolver.java index 74d8b5d..f029e10 100644 --- a/src/main/java/org/gcube/datatransfer/resolver/services/StorageIDResolver.java +++ b/src/main/java/org/gcube/datatransfer/resolver/services/StorageIDResolver.java @@ -340,11 +340,12 @@ public class StorageIDResolver { * @return the storage client instance */ protected static IClient getStorageClientInstance(MemoryType memory) { - if ((!Objects.isNull(storageManagerClient)) && (storageManagerClient.getGcubeMemoryType().equals(memory))) + if ((!Objects.isNull(storageManagerClient)) && (storageManagerClient.getGcubeMemoryType().equals(memory))) { + LOG.debug("reusing the same storage-client object"); return storageManagerClient; - else { + }else { if(!Objects.isNull(storageManagerClient)) { - LOG.debug("going to close an old storage-client instance"); + LOG.debug("going to close an old storage-client instance on "+storageManagerClient.getGcubeMemoryType()); try { storageManagerClient.forceClose(); LOG.debug("storage-client closed"); @@ -352,7 +353,7 @@ public class StorageIDResolver { LOG.warn("Some problem occurred during the close operation:"+e.getMessage()+" Going to open another connection"); } } - LOG.debug("initializing a new storage-client instance"); + LOG.debug("initializing a new storage-client instance on "+memory); storageManagerClient=new StorageClient(StorageIDResolver.class.getName(), StorageIDResolver.class.getSimpleName(), STORAGEID_RESOLVER, STORAGE_ACCESS_TYPE, memory, STORAGE_BACKEND_TYPE).getClient(); return storageManagerClient; }