Fix asynchronous resource cleanup on failed connect #1768

redis · Jun 18, 2021 · 63728f8 · 63728f8
1 parent cacdfc6
commit 63728f8
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/io/lettuce/core/RedisClient.java b/src/main/java/io/lettuce/core/RedisClient.java
@@ -290,7 +290,7 @@ private <K, V> ConnectionFuture<StatefulRedisConnection<K, V>> connectStandalone
         future.whenComplete((channelHandler, throwable) -> {
 
             if (throwable != null) {
-                connection.close();
+                connection.closeAsync();
             }
         });
 
@@ -602,8 +602,8 @@ private <K, V> ConnectionFuture<StatefulRedisSentinelConnection<K, V>> doConnect
         return sync.thenApply(ignore -> (StatefulRedisSentinelConnection<K, V>) connection).whenComplete((ignore, e) -> {
 
             if (e != null) {
-                logger.warn("Cannot connect Redis Sentinel at " + redisURI + ": " + e.toString());
-                connection.close();
+                logger.warn("Cannot connect Redis Sentinel at " + redisURI + ": " + e);
+                connection.closeAsync();
             }
         });
     }