From d79708ffc2fc48b0e82cf775d18b6f146415e6cf Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Wed, 10 Feb 2016 15:03:28 +0300
Subject: [PATCH] reverted.  #402

---
 src/main/java/org/redisson/command/CommandAsyncService.java | 4 ----
 src/main/java/org/redisson/command/CommandBatchService.java | 4 ----
 2 files changed, 8 deletions(-)

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;