diff --git a/redisson/src/main/java/org/redisson/executor/RedissonExecutorRemoteService.java b/redisson/src/main/java/org/redisson/executor/RedissonExecutorRemoteService.java index d88a08744..470df72b8 100644 --- a/redisson/src/main/java/org/redisson/executor/RedissonExecutorRemoteService.java +++ b/redisson/src/main/java/org/redisson/executor/RedissonExecutorRemoteService.java @@ -84,7 +84,7 @@ public class RedissonExecutorRemoteService extends RedissonRemoteService { protected void invokeMethod(Class remoteInterface, RBlockingQueue requestQueue, RemoteServiceRequest request, RemoteServiceMethod method, String responseName, ExecutorService executor, RFuture cancelRequestFuture, AtomicReference responseHolder) { if (taskTimeout > 0) { commandExecutor.getConnectionManager().getGroup().schedule(() -> { - ((RPromise)cancelRequestFuture).trySuccess(new RemoteServiceCancelRequest(true, false)); + ((RPromise) cancelRequestFuture).trySuccess(new RemoteServiceCancelRequest(true, false)); }, taskTimeout, TimeUnit.MILLISECONDS); } super.invokeMethod(remoteInterface, requestQueue, request, method, responseName, executor, cancelRequestFuture, responseHolder);