diff --git a/redisson/src/main/java/org/redisson/RedissonRemoteService.java b/redisson/src/main/java/org/redisson/RedissonRemoteService.java index 742f589ac..39f4fe63c 100644 --- a/redisson/src/main/java/org/redisson/RedissonRemoteService.java +++ b/redisson/src/main/java/org/redisson/RedissonRemoteService.java @@ -245,7 +245,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS if (e instanceof RedissonShutdownException) { return; } - log.error("Can't process the remote service request.", e); + log.error("Can't process the remote service request. A new attempt has been made.", e); // re-subscribe after a failed takeAsync commandExecutor.getServiceManager().newTimeout(task -> { subscribe(remoteInterface, requestQueue, executor, bean); @@ -280,7 +280,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS if (exc instanceof RedissonShutdownException) { return; } - log.error("Can't process the remote service request with id {}", requestId, exc); + log.error("Can't process the remote service request with id {}. Try to increase 'retryInterval' and/or 'retryAttempts' settings", requestId, exc); // re-subscribe after a failed takeAsync resubscribe(remoteInterface, requestQueue, executor, bean); @@ -330,7 +330,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS if (ex instanceof RedissonShutdownException) { return; } - log.error("Can't send ack for request: {}", request, ex); + log.error("Can't send ack for request: {}. Try to increase 'retryInterval' and/or 'retryAttempts' settings", request, ex); // re-subscribe after a failed send (ack) resubscribe(remoteInterface, requestQueue, executor, bean); @@ -350,7 +350,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS if (exce instanceof RedissonShutdownException) { return; } - log.error("Can't send ack for request: {}", request, exce); + log.error("Can't send ack for request: {}. Try to increase 'retryInterval' and/or 'retryAttempts' settings", request, exce); // re-subscribe after a failed send (ack) resubscribe(remoteInterface, requestQueue, executor, bean); @@ -427,7 +427,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS if (exc instanceof RedissonShutdownException) { return; } - log.error("Can't send response: {} for request: {}", response, request, exc); + log.error("Can't send response: {} for request: {}. Try to increase 'retryInterval' and/or 'retryAttempts' settings", response, request, exc); } resubscribe(remoteInterface, requestQueue, executor, method.getBean()); diff --git a/redisson/src/main/java/org/redisson/remote/BaseRemoteProxy.java b/redisson/src/main/java/org/redisson/remote/BaseRemoteProxy.java index 9dbbecdf0..1392d8e9c 100644 --- a/redisson/src/main/java/org/redisson/remote/BaseRemoteProxy.java +++ b/redisson/src/main/java/org/redisson/remote/BaseRemoteProxy.java @@ -191,7 +191,7 @@ public abstract class BaseRemoteProxy { return; } - log.error("Can't get response from {}", responseQueueName, e); + log.error("Can't get response from {}. Try to increase 'retryInterval' and/or 'retryAttempts' settings", responseQueueName, e); return; }