gCubeSystem
/
storage-manager-s3-plugin
14
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: gCubeSystem:4a1c7d8a6d9bfa0adc8f6b54c3e5f82ad85d3340
Branches Tags
gCubeSystem:master
..
compare: gCubeSystem:c737c526ebc0615e09ddfd73ad61e79c85dbfaf4
Branches Tags
gCubeSystem:master

2 Commits
4a1c7d8a6d ... c737c526eb

Author SHA1 Message Date
Roberto Cirillo c737c526eb Merge branch 'master' of http://code-repo.d4science.org/gCubeSystem/storage-manager-s3-plugin 2021-10-14 10:14:50 +02:00
Roberto Cirillo a63695d803 change storage-manager-core range; add forceClose method 2021-10-14 10:14:38 +02:00
1 changed files with 12 additions and 2 deletions
Show Stats Expand all files Collapse all files

14
src/main/java/org/gcube/contentmanagement/blobstorage/transport/plugin/S3PluginManager.java
View File

@ -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 {
}
}