Skip to content

Commit 854db43

Browse files
committed
Added connect timeout.
1 parent 2f6c134 commit 854db43

3 files changed

Lines changed: 4 additions & 0 deletions

File tree

src/main/java/org/prebid/cache/repository/aerospike/AerospikePropertyConfiguration.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ public class AerospikePropertyConfiguration {
4343
private boolean preventUUIDDuplication;
4444
private int socketTimeout;
4545
private int totalTimeout;
46+
private int connectTimeout;
4647

4748
private static final int DEFAULT_PORT = 3000;
4849

@@ -67,6 +68,7 @@ public static boolean isAerospikeCluster(@NotNull String hostList) {
6768
@Bean
6869
Policy readPolicy() {
6970
final Policy policy = new Policy();
71+
policy.setConnectTimeout(connectTimeout);
7072
policy.setTimeouts(socketTimeout, totalTimeout);
7173
return policy;
7274
}

src/main/java/org/prebid/cache/repository/aerospike/AerospikeRepositoryImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ policy, new Key(configuration.getNamespace(), "", id)))
7878

7979
private WritePolicy writePolicy() {
8080
final WritePolicy writePolicy = new WritePolicy();
81+
writePolicy.setConnectTimeout(configuration.getConnectTimeout());
8182
writePolicy.setTimeouts(configuration.getSocketTimeout(), configuration.getTotalTimeout());
8283
if (configuration.isPreventUUIDDuplication()) {
8384
writePolicy.recordExistsAction = RecordExistsAction.CREATE_ONLY;

src/main/resources/application.yml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,7 @@ spring:
125125
prevent_UUID_duplication: true
126126
socket_timeout: 30000
127127
total_timeout: 1000
128+
connect_timeout: 0
128129

129130
---
130131
# dev

0 commit comments

Comments
 (0)