diff --git a/pom.xml b/pom.xml
index b2b361a33..18ef40a8d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,7 +21,7 @@
1.9.2
1.4.8
2.6.0
- 5.1.5.RELEASE
+ 5.1.6.RELEASE
3.0.1
1.01
4.1.22.Final
diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java
index 0bb386c38..0f7d7db63 100644
--- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java
+++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java
@@ -1013,7 +1013,7 @@ public class LettuceConnectionFactory
.map(ClusterClientOptions.class::cast) //
.orElseGet(() -> {
return clientOptions //
- .map(LettuceConnectionFactory::toClusterClientOptions) //
+ .map(it -> ClusterClientOptions.builder(it).build()) //
.orElseGet(ClusterClientOptions::create);
});
@@ -1024,22 +1024,6 @@ public class LettuceConnectionFactory
return clusterClientOptions;
}
- // TODO: Replace with Lettuce 5.1.6 ClusterClientOptions.builder(ClientOptions)
- private static ClusterClientOptions toClusterClientOptions(ClientOptions it) {
-
- return ClusterClientOptions.builder() //
- .autoReconnect(it.isAutoReconnect()) //
- .cancelCommandsOnReconnectFailure(it.isCancelCommandsOnReconnectFailure()) //
- .disconnectedBehavior(it.getDisconnectedBehavior()) //
- .pingBeforeActivateConnection(it.isPingBeforeActivateConnection()) //
- .requestQueueSize(it.getRequestQueueSize()) //
- .socketOptions(it.getSocketOptions()) //
- .sslOptions(it.getSslOptions()) //
- .suspendReconnectOnProtocolFailure(it.isSuspendReconnectOnProtocolFailure())//
- .timeoutOptions(it.getTimeoutOptions()) //
- .build();
- }
-
private RedisURI getSentinelRedisURI() {
RedisURI redisUri = LettuceConverters.sentinelConfigurationToRedisURI(