77import com .aerospike .client .async .NettyEventLoops ;
88import com .aerospike .client .policy .ClientPolicy ;
99import com .aerospike .client .policy .Policy ;
10+ import com .aerospike .client .policy .Replica ;
1011import io .netty .channel .EventLoopGroup ;
1112import io .netty .channel .nio .NioEventLoopGroup ;
1213import jakarta .validation .constraints .NotNull ;
@@ -45,6 +46,8 @@ public class AerospikePropertyConfiguration {
4546 private int totalTimeout ;
4647 private int connectTimeout ;
4748 private int minConnsPerNode ;
49+ private int maxConnsPerNode = 100 ;
50+ private Replica readPolicy = Replica .SEQUENCE ;
4851
4952 private static final int DEFAULT_PORT = 3000 ;
5053
@@ -71,6 +74,7 @@ Policy readPolicy() {
7174 final Policy policy = new Policy ();
7275 policy .setConnectTimeout (connectTimeout );
7376 policy .setTimeouts (socketTimeout , totalTimeout );
77+ policy .setReplica (readPolicy );
7478 return policy ;
7579 }
7680
@@ -94,6 +98,7 @@ ClientPolicy clientPolicy() {
9498 ClientPolicy clientPolicy = new ClientPolicy ();
9599 clientPolicy .eventLoops = eventLoops ();
96100 clientPolicy .minConnsPerNode = minConnsPerNode ;
101+ clientPolicy .maxConnsPerNode = maxConnsPerNode ;
97102 return clientPolicy ;
98103 }
99104
0 commit comments