DATAREDIS-951 - Upgrade to Lettuce 5.1.6.

Replace custom builder adapter with ClusterClientOptions.builder(ClientOptions).
This commit is contained in:
Mark Paluch
2019-03-27 08:51:06 +01:00
parent 9ce10bb08f
commit ce5edb7203
2 changed files with 2 additions and 18 deletions

View File

@@ -21,7 +21,7 @@
<beanutils>1.9.2</beanutils>
<xstream>1.4.8</xstream>
<pool>2.2</pool>
<lettuce>5.1.5.RELEASE</lettuce>
<lettuce>5.1.6.RELEASE</lettuce>
<jedis>2.9.3</jedis>
<multithreadedtc>1.01</multithreadedtc>
<netty>4.1.22.Final</netty>

View File

@@ -982,7 +982,7 @@ public class LettuceConnectionFactory
.map(ClusterClientOptions.class::cast) //
.orElseGet(() -> {
return clientOptions //
.map(LettuceConnectionFactory::toClusterClientOptions) //
.map(it -> ClusterClientOptions.builder(it).build()) //
.orElseGet(ClusterClientOptions::create);
});
@@ -993,22 +993,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(