diff --git a/redisson/src/main/java/org/redisson/RedissonRemoteService.java b/redisson/src/main/java/org/redisson/RedissonRemoteService.java index 4a847a1ea..fecb9747a 100644 --- a/redisson/src/main/java/org/redisson/RedissonRemoteService.java +++ b/redisson/src/main/java/org/redisson/RedissonRemoteService.java @@ -226,7 +226,6 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS return tryExecuteAsync(remoteInterface, object, -1, null); } - @SuppressWarnings("MethodLength") private <T> void subscribe(Class<T> remoteInterface, RBlockingQueue<String> requestQueue, ExecutorService executor, Object bean) { Entry entry = remoteMap.get(remoteInterface); @@ -360,13 +359,6 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS } executeMethod(remoteInterface, requestQueue, executor, request, bean); - }) - .exceptionally(exack -> { - if (exack instanceof RedissonShutdownException) { - return null; - } - log.error("Can't send ack for request: {}", request, exack); - return null; }); }); } else {