|
|
@ -226,6 +226,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS
|
|
|
|
return tryExecuteAsync(remoteInterface, object, -1, null);
|
|
|
|
return tryExecuteAsync(remoteInterface, object, -1, null);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@SuppressWarnings("MethodLength")
|
|
|
|
private <T> void subscribe(Class<T> remoteInterface, RBlockingQueue<String> requestQueue,
|
|
|
|
private <T> void subscribe(Class<T> remoteInterface, RBlockingQueue<String> requestQueue,
|
|
|
|
ExecutorService executor, Object bean) {
|
|
|
|
ExecutorService executor, Object bean) {
|
|
|
|
Entry entry = remoteMap.get(remoteInterface);
|
|
|
|
Entry entry = remoteMap.get(remoteInterface);
|
|
|
@ -359,6 +360,13 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
executeMethod(remoteInterface, requestQueue, executor, request, bean);
|
|
|
|
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 {
|
|
|
|
} else {
|
|
|
|