Skip to content

Commit 1db10e9

Browse files
committed
fixes DynamoDBBuilderASync
1 parent d4d13f1 commit 1db10e9

File tree

1 file changed

+50
-50
lines changed

1 file changed

+50
-50
lines changed

dynamodb-driver/src/main/java/org/jnosql/diana/dynamodb/DynamoDBBuilderASync.java

Lines changed: 50 additions & 50 deletions
Original file line numberDiff line numberDiff line change
@@ -24,56 +24,56 @@
2424
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient;
2525
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClientBuilder;
2626

27-
public class DynamoDBBuilderASync implements DynamoDBBuilder{
28-
29-
30-
private final DynamoDbAsyncClientBuilder dynamoDB = DynamoDbAsyncClient.builder();
31-
32-
33-
private String awsAccessKey;
34-
private String awsSecretAccess;
35-
36-
@Override
37-
public void endpoint(String endpoint) {
38-
dynamoDB.endpointOverride(URI.create(endpoint));
39-
40-
}
41-
42-
@Override
43-
public void region(String region) {
44-
dynamoDB.region(Region.of(region));
45-
}
46-
47-
@Override
48-
public void profile(String profile) {
49-
dynamoDB.credentialsProvider(ProfileCredentialsProvider.builder()
27+
public class DynamoDBBuilderASync implements DynamoDBBuilder {
28+
29+
30+
private final DynamoDbAsyncClientBuilder dynamoDB = DynamoDbAsyncClient.builder();
31+
32+
33+
private String awsAccessKey;
34+
private String awsSecretAccess;
35+
36+
@Override
37+
public void endpoint(String endpoint) {
38+
dynamoDB.endpointOverride(URI.create(endpoint));
39+
40+
}
41+
42+
@Override
43+
public void region(String region) {
44+
dynamoDB.region(Region.of(region));
45+
}
46+
47+
@Override
48+
public void profile(String profile) {
49+
dynamoDB.credentialsProvider(ProfileCredentialsProvider.builder()
5050
.profileName(profile)
5151
.build());
52-
53-
}
54-
55-
public DynamoDbAsyncClient build() {
56-
57-
boolean accessKey = awsAccessKey != null && !awsAccessKey.equals("");
58-
boolean secretAccess = awsSecretAccess != null && !awsSecretAccess.equals("");
59-
60-
if(accessKey && secretAccess){
61-
62-
AwsBasicCredentials awsBasicCredentials = AwsBasicCredentials.create(awsAccessKey,awsSecretAccess);
63-
AwsCredentialsProvider staticCredentialsProvider = StaticCredentialsProvider.create(awsBasicCredentials);
64-
dynamoDB.credentialsProvider(staticCredentialsProvider);
65-
}
66-
67-
return dynamoDB.build();
68-
}
69-
70-
@Override
71-
public void awsAccessKey(String awsAccessKey) {
72-
this.awsAccessKey = awsAccessKey;
73-
}
74-
75-
@Override
76-
public void awsSecretAccess(String awsSecretAccess) {
77-
this.awsSecretAccess = awsSecretAccess;
78-
}
52+
53+
}
54+
55+
public DynamoDbAsyncClient build() {
56+
57+
boolean accessKey = awsAccessKey != null && !awsAccessKey.equals("");
58+
boolean secretAccess = awsSecretAccess != null && !awsSecretAccess.equals("");
59+
60+
if (accessKey && secretAccess) {
61+
62+
AwsBasicCredentials awsBasicCredentials = AwsBasicCredentials.create(awsAccessKey, awsSecretAccess);
63+
AwsCredentialsProvider staticCredentialsProvider = StaticCredentialsProvider.create(awsBasicCredentials);
64+
dynamoDB.credentialsProvider(staticCredentialsProvider);
65+
}
66+
67+
return dynamoDB.build();
68+
}
69+
70+
@Override
71+
public void awsAccessKey(String awsAccessKey) {
72+
this.awsAccessKey = awsAccessKey;
73+
}
74+
75+
@Override
76+
public void awsSecretAccess(String awsSecretAccess) {
77+
this.awsSecretAccess = awsSecretAccess;
78+
}
7979
}

0 commit comments

Comments
 (0)