Merge pull request #5442 from redisson/revert-5427-master

Revert "Log swallowed exception in RedissonRemoteService sending request ack"
pull/5443/head
Nikita Koksharov 1 year ago committed by GitHub
commit 26272f8c1c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -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 {

Loading…
Cancel
Save