From e0c8342c14fa949a054b7d11ec7ddfe5e7295c83 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Sat, 18 Nov 2023 11:02:41 +0300 Subject: [PATCH] Revert "Log swallowed exception in RedissonRemoteService sending request ack" --- .../src/main/java/org/redisson/RedissonRemoteService.java | 8 -------- 1 file changed, 8 deletions(-) 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 void subscribe(Class remoteInterface, RBlockingQueue 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 {