diff --git a/pom.xml b/pom.xml index 81543b0..78a71a3 100644 --- a/pom.xml +++ b/pom.xml @@ -32,7 +32,7 @@ org.gcube.contentmanagement storage-manager-core - [3.0.0-SNAPSHOT, 4.0.0-SNAPSHOT) + [4.0.0-SNAPSHOT, 5.0.0-SNAPSHOT) diff --git a/src/main/java/org/gcube/contentmanagement/blobstorage/transport/plugin/S3PluginManager.java b/src/main/java/org/gcube/contentmanagement/blobstorage/transport/plugin/S3PluginManager.java index 9e87b7c..f164b76 100644 --- a/src/main/java/org/gcube/contentmanagement/blobstorage/transport/plugin/S3PluginManager.java +++ b/src/main/java/org/gcube/contentmanagement/blobstorage/transport/plugin/S3PluginManager.java @@ -45,6 +45,7 @@ public class S3PluginManager extends TransportManager { private Region region; private String token; + @Override public String getName() { @@ -61,11 +62,12 @@ public class S3PluginManager extends TransportManager { String writeConcern, String readConcern, String token, String region) { initBackend(server,user,pass, memoryType,dbNames, writeConcern, readConcern, token, region); } - + + @Override public void initBackend(String[] server, String accessKey, String secretAccessKey, MemoryType memoryType, String[] dbNames, String writeConcern, String readConcern, String token, String region) { - + this.memoryType=memoryType; AwsSessionCredentials awsCreds =null; if(!Objects.isNull(getToken())) awsCreds = AwsSessionCredentials.create(accessKey, secretAccessKey, token); @@ -212,6 +214,12 @@ public class S3PluginManager extends TransportManager { s3.close(); } + + @Override + public void forceClose() { + s3.close(); + + } @Override public void setFileProperty(String remotePath, String propertyField, String propertyValue) { @@ -243,5 +251,7 @@ public class S3PluginManager extends TransportManager { } + + }