Fixed - RRemoteService may cause CPU spike after Master failover

pull/5661/head
Nikita Koksharov 1 year ago
parent 844d342d0f
commit 1449ec00e2

@ -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;
}

Loading…
Cancel
Save