refactoring

4 years ago · 0da7990f32
parent ca9bd8e7a6
commit 0da7990f32
1 changed files with 1 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/executor/TasksRunnerService.java
+++ b/redisson/src/main/java/org/redisson/executor/TasksRunnerService.java
@ -231,7 +231,7 @@ public class TasksRunnerService implements RemoteExecutorService {
            return;
        }

-        ((Redisson) redisson).getConnectionManager().newTimeout(new TimerTask() {
+        commandExecutor.getConnectionManager().newTimeout(new TimerTask() {
            @Override
            public void run(Timeout timeout) throws Exception {
                renewRetryTime(requestId);