diff --git a/src/main/java/org/redisson/command/CommandAsyncService.java b/src/main/java/org/redisson/command/CommandAsyncService.java
index 51683d586..3f2a1c2a1 100644
--- a/src/main/java/org/redisson/command/CommandAsyncService.java
+++ b/src/main/java/org/redisson/command/CommandAsyncService.java
@@ -460,6 +460,7 @@ public class CommandAsyncService implements CommandAsyncExecutor {
         }
 
         if (!details.getConnectionFuture().isSuccess()) {
+            connectionManager.getShutdownLatch().release();
             details.setException(convertException(details.getConnectionFuture()));
             return;
         }
diff --git a/src/main/java/org/redisson/command/CommandBatchService.java b/src/main/java/org/redisson/command/CommandBatchService.java
index 514c12e32..0908634c4 100644
--- a/src/main/java/org/redisson/command/CommandBatchService.java
+++ b/src/main/java/org/redisson/command/CommandBatchService.java
@@ -333,6 +333,7 @@ public class CommandBatchService extends CommandReactiveService {
         }
 
         if (!connFuture.isSuccess()) {
+            connectionManager.getShutdownLatch().release();
             details.setException(convertException(connFuture));
             return;
         }