Enable Lettuce adaptive topology refreshes.
This commit is contained in:
parent
b70d076324
commit
cc3e5d23e4
|
@ -14,6 +14,7 @@ import io.github.resilience4j.retry.Retry;
|
||||||
import io.lettuce.core.RedisCommandTimeoutException;
|
import io.lettuce.core.RedisCommandTimeoutException;
|
||||||
import io.lettuce.core.RedisURI;
|
import io.lettuce.core.RedisURI;
|
||||||
import io.lettuce.core.cluster.ClusterClientOptions;
|
import io.lettuce.core.cluster.ClusterClientOptions;
|
||||||
|
import io.lettuce.core.cluster.ClusterTopologyRefreshOptions;
|
||||||
import io.lettuce.core.cluster.RedisClusterClient;
|
import io.lettuce.core.cluster.RedisClusterClient;
|
||||||
import io.lettuce.core.cluster.api.StatefulRedisClusterConnection;
|
import io.lettuce.core.cluster.api.StatefulRedisClusterConnection;
|
||||||
import io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection;
|
import io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection;
|
||||||
|
@ -78,7 +79,13 @@ public class FaultTolerantRedisCluster {
|
||||||
|
|
||||||
this.clusterClient = clusterClient;
|
this.clusterClient = clusterClient;
|
||||||
this.clusterClient.setDefaultTimeout(commandTimeout);
|
this.clusterClient.setDefaultTimeout(commandTimeout);
|
||||||
this.clusterClient.setOptions(ClusterClientOptions.builder().validateClusterNodeMembership(false).build());
|
this.clusterClient.setOptions(ClusterClientOptions.builder()
|
||||||
|
.validateClusterNodeMembership(false)
|
||||||
|
.topologyRefreshOptions(ClusterTopologyRefreshOptions.builder()
|
||||||
|
.enablePeriodicRefresh()
|
||||||
|
.enableAllAdaptiveRefreshTriggers()
|
||||||
|
.build())
|
||||||
|
.build());
|
||||||
|
|
||||||
this.stringConnection = clusterClient.connect();
|
this.stringConnection = clusterClient.connect();
|
||||||
this.binaryConnection = clusterClient.connect(ByteArrayCodec.INSTANCE);
|
this.binaryConnection = clusterClient.connect(ByteArrayCodec.INSTANCE);
|
||||||
|
|
Loading…
Reference in New Issue