From 4c897806f6a84a5bc9347ff92c007ae517a03fa1 Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 22 Dec 2015 15:17:56 +0300 Subject: [PATCH] Connection leak fixed. #338 --- src/main/java/org/redisson/command/CommandAsyncService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/redisson/command/CommandAsyncService.java b/src/main/java/org/redisson/command/CommandAsyncService.java index d5b38a246..cc1259964 100644 --- a/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/src/main/java/org/redisson/command/CommandAsyncService.java @@ -505,7 +505,7 @@ public class CommandAsyncService implements CommandAsyncExecutor { } private void releaseConnection(NodeSource source, AsyncDetails details, RedisConnection connection) { - if (details.getAttemptPromise().isCancelled()) { + if (!details.getConnectionFuture().isSuccess()) { return; }