diff --git a/redisson/src/main/java/org/redisson/executor/TasksRunnerService.java b/redisson/src/main/java/org/redisson/executor/TasksRunnerService.java index f8fa7fd29..4deea3c51 100644 --- 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);