From 1449ec00e28002b10e8bc563a12f7746f978c571 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 27 Feb 2024 10:56:11 +0300 Subject: [PATCH] Fixed - RRemoteService may cause CPU spike after Master failover --- .../src/main/java/org/redisson/RedissonRemoteService.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/RedissonRemoteService.java b/redisson/src/main/java/org/redisson/RedissonRemoteService.java index 77f9dd75b..742f589ac 100644 --- a/redisson/src/main/java/org/redisson/RedissonRemoteService.java +++ b/redisson/src/main/java/org/redisson/RedissonRemoteService.java @@ -247,7 +247,10 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS } log.error("Can't process the remote service request.", e); // re-subscribe after a failed takeAsync - subscribe(remoteInterface, requestQueue, executor, bean); + commandExecutor.getServiceManager().newTimeout(task -> { + subscribe(remoteInterface, requestQueue, executor, bean); + }, commandExecutor.getServiceManager().getConfig().getRetryInterval(), TimeUnit.MILLISECONDS); + return; }