Fix asynchronous resource cleanup on failed connect #1768

When a cluster node connection fails, we call now the asynchronous closeAsync method instead of the blocking close method.
redis · Jun 9, 2021 · 3c78ca0 · 3c78ca0
1 parent a96e243
commit 3c78ca0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/io/lettuce/core/cluster/RedisClusterClient.java b/src/main/java/io/lettuce/core/cluster/RedisClusterClient.java
@@ -552,7 +552,7 @@ <K, V> ConnectionFuture<StatefulRedisConnection<K, V>> connectToNodeAsync(RedisC
 
         return connectionFuture.whenComplete((conn, throwable) -> {
             if (throwable != null) {
-                connection.close();
+                connection.closeAsync();
             }
         });
     }
@@ -597,7 +597,7 @@ <K, V> ConnectionFuture<StatefulRedisPubSubConnection<K, V>> connectPubSubToNode
                 () -> new PubSubCommandHandler<>(getClusterClientOptions(), getResources(), codec, endpoint));
         return connectionFuture.whenComplete((conn, throwable) -> {
             if (throwable != null) {
-                connection.close();
+                connection.closeAsync();
             }
         });
     }