refactoring

6 years ago · 5b40913b96
parent 76bd80eb08
commit 5b40913b96
1 changed files with 1 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java
+++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java
@ -938,8 +938,7 @@ public class CommandAsyncService implements CommandAsyncExecutor {
        TimerTask timeoutTask = new TimerTask() {
            @Override
            public void run(Timeout timeout) throws Exception {
-                if (!details.getAttemptPromise().isDone() 
-                        && details.getAttempt() < connectionManager.getConfig().getRetryAttempts()) {
+                if (details.getAttempt() < connectionManager.getConfig().getRetryAttempts()) {
                    if (!details.getAttemptPromise().cancel(false)) {
                        return;
                    }