From 086ccf36880c4ef74df1e065a1276f07e72e00b6 Mon Sep 17 00:00:00 2001 From: ggivo Date: Thu, 12 Dec 2024 11:44:06 +0200 Subject: [PATCH] format --- .../java/io/lettuce/core/StatefulRedisConnectionImpl.java | 1 - src/main/java/io/lettuce/core/cluster/RedisClusterClient.java | 4 ---- 2 files changed, 5 deletions(-) diff --git a/src/main/java/io/lettuce/core/StatefulRedisConnectionImpl.java b/src/main/java/io/lettuce/core/StatefulRedisConnectionImpl.java index 038d23a96..57d164dc2 100644 --- a/src/main/java/io/lettuce/core/StatefulRedisConnectionImpl.java +++ b/src/main/java/io/lettuce/core/StatefulRedisConnectionImpl.java @@ -394,7 +394,6 @@ public void setAuthenticationHandler(RedisAuthenticationHandler handler) { authHandler = handler; } - private void dispatchAuthCommand(RedisCredentials credentials) { if (credentials == null) { return; diff --git a/src/main/java/io/lettuce/core/cluster/RedisClusterClient.java b/src/main/java/io/lettuce/core/cluster/RedisClusterClient.java index 0a08389c8..ef8690a2b 100644 --- a/src/main/java/io/lettuce/core/cluster/RedisClusterClient.java +++ b/src/main/java/io/lettuce/core/cluster/RedisClusterClient.java @@ -565,8 +565,6 @@ ConnectionFuture> connectToNodeAsync(RedisC getFirstUri(), socketAddressSupplier, () -> new CommandHandler(getClusterClientOptions(), getResources(), endpoint)); - - return connectionFuture.whenComplete((conn, throwable) -> { if (throwable != null) { connection.closeAsync(); @@ -637,8 +635,6 @@ ConnectionFuture> connectPubSubToNode getFirstUri(), socketAddressSupplier, () -> new PubSubCommandHandler<>(getClusterClientOptions(), getResources(), codec, endpoint)); - - return connectionFuture.whenComplete((conn, throwable) -> { if (throwable != null) { connection.closeAsync();