reverted. redisson#402

massinger · Feb 10, 2016 · d79708f · d79708f
1 parent eb0a836
commit d79708f
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 8 deletions.
diff --git 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
@@ -233,10 +233,6 @@ public void run(Timeout timeout) throws Exception {
                     }
                 }
 
-                if (connectionManager.isShuttingDown()) {
-                    return;
-                }
-
                 if (mainPromise.isCancelled()) {
                     attemptPromise.cancel(false);
                     return;
-Original file line number
+Diff line change
@@ Expand Up / @@ -233,10 +233,6 @@ public void run(Timeout timeout) throws Exception { @@
                         }
                     }
-                    if (connectionManager.isShuttingDown()) {
-                        return;
-                    }
                     if (mainPromise.isCancelled()) {
                         attemptPromise.cancel(false);
                         return;
@@ Expand Down @@