|
|
@ -113,10 +113,10 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public void operationComplete(Future<RemoteServiceRequest> future) throws Exception {
|
|
|
|
public void operationComplete(Future<RemoteServiceRequest> future) throws Exception {
|
|
|
|
if (!future.isSuccess()) {
|
|
|
|
if (!future.isSuccess()) {
|
|
|
|
log.error("Can't process the remote service request.", future.cause());
|
|
|
|
|
|
|
|
if (future.cause() instanceof RedissonShutdownException) {
|
|
|
|
if (future.cause() instanceof RedissonShutdownException) {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
log.error("Can't process the remote service request.", future.cause());
|
|
|
|
// re-subscribe after a failed takeAsync
|
|
|
|
// re-subscribe after a failed takeAsync
|
|
|
|
subscribe(remoteInterface, requestQueue, executor);
|
|
|
|
subscribe(remoteInterface, requestQueue, executor);
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|