Compare commits
2 Commits
4a1c7d8a6d
...
c737c526eb
Author | SHA1 | Date |
---|---|---|
Roberto Cirillo | c737c526eb | |
Roberto Cirillo | a63695d803 |
|
@ -45,6 +45,7 @@ public class S3PluginManager extends TransportManager {
|
||||||
private Region region;
|
private Region region;
|
||||||
private String token;
|
private String token;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String getName() {
|
public String getName() {
|
||||||
|
@ -61,11 +62,12 @@ public class S3PluginManager extends TransportManager {
|
||||||
String writeConcern, String readConcern, String token, String region) {
|
String writeConcern, String readConcern, String token, String region) {
|
||||||
initBackend(server,user,pass, memoryType,dbNames, writeConcern, readConcern, token, region);
|
initBackend(server,user,pass, memoryType,dbNames, writeConcern, readConcern, token, region);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void initBackend(String[] server, String accessKey, String secretAccessKey, MemoryType memoryType, String[] dbNames,
|
public void initBackend(String[] server, String accessKey, String secretAccessKey, MemoryType memoryType, String[] dbNames,
|
||||||
String writeConcern, String readConcern, String token, String region) {
|
String writeConcern, String readConcern, String token, String region) {
|
||||||
|
this.memoryType=memoryType;
|
||||||
AwsSessionCredentials awsCreds =null;
|
AwsSessionCredentials awsCreds =null;
|
||||||
if(!Objects.isNull(getToken()))
|
if(!Objects.isNull(getToken()))
|
||||||
awsCreds = AwsSessionCredentials.create(accessKey, secretAccessKey, token);
|
awsCreds = AwsSessionCredentials.create(accessKey, secretAccessKey, token);
|
||||||
|
@ -212,6 +214,12 @@ public class S3PluginManager extends TransportManager {
|
||||||
s3.close();
|
s3.close();
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void forceClose() {
|
||||||
|
s3.close();
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void setFileProperty(String remotePath, String propertyField, String propertyValue) {
|
public void setFileProperty(String remotePath, String propertyField, String propertyValue) {
|
||||||
|
@ -243,5 +251,7 @@ public class S3PluginManager extends TransportManager {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue