diff --git a/src/main/java/org/redisson/command/CommandAsyncService.java b/src/main/java/org/redisson/command/CommandAsyncService.java
index 3376248b850..d8c44d2fac6 100644
--- a/src/main/java/org/redisson/command/CommandAsyncService.java
+++ b/src/main/java/org/redisson/command/CommandAsyncService.java
@@ -390,10 +390,6 @@ public void run(Timeout t) throws Exception {
                     }
                 }
 
-                if (connectionManager.isShuttingDown()) {
-                    return;
-                }
-
                 if (details.getMainPromise().isCancelled()) {
                     if (details.getAttemptPromise().cancel(false)) {
                         AsyncDetails.release(details);
diff --git a/src/main/java/org/redisson/command/CommandBatchService.java b/src/main/java/org/redisson/command/CommandBatchService.java
index 4d8dd33cb4e..6bf4083cb2f 100644
--- a/src/main/java/org/redisson/command/CommandBatchService.java
+++ b/src/main/java/org/redisson/command/CommandBatchService.java
@@ -233,10 +233,6 @@ public void run(Timeout timeout) throws Exception {
                     }
                 }
 
-                if (connectionManager.isShuttingDown()) {
-                    return;
-                }
-
                 if (mainPromise.isCancelled()) {
                     attemptPromise.cancel(false);
                     return;