protected void |
ClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request,
RemoteOperationsExecutorProxy proxy,
ClusterRemoteOperationRouter.ExecutionStatus status) |
protected boolean |
ClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request,
RemoteOperationsExecutorProxy proxy) |
<T extends RemoteOperationResult> RemoteOperationFutureListener<T> |
ClusterRemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener) |
<T extends RemoteOperationResult> void |
ClusterRemoteOperationRouter.execute(RemoteOperationRequest<T> request) |
<T extends RemoteOperationResult> T |
RemoteOperationsExecutorProxy.execute(RemoteOperationRequest<T> request) |
<T extends RemoteOperationResult> void |
RemoteOperationsExecutorProxy.executeAsync(RemoteOperationRequest<T> request,
AsyncFutureListener<T> listener) |
<T extends RemoteOperationResult> void |
ClusterRemoteOperationRouter.executeAsync(RemoteOperationRequest<T> request,
RemoteOperationFutureListener<T> futureListener) |
void |
ClusterRemoteOperationRouter.executeOneway(RemoteOperationRequest<?> request) |
void |
RemoteOperationsExecutorProxy.executeOneway(RemoteOperationRequest<?> request) |
RemoteOperationsExecutorProxy |
SpaceProxyLoadBalancingStrategy.findActiveMember(RemoteOperationRequest<?> request,
long initialFailureTime,
RemoteOperationsExecutorProxy oldCandidate) |
RemoteOperationsExecutorProxy |
SpaceProxyLoadBalancingStrategy.findActiveMemberUninterruptibly(RemoteOperationRequest<?> request,
long initialFailureTime,
RemoteOperationsExecutorProxy proxy) |
String |
RemoteOperationsExecutorsCluster.generateTimeoutErrorMessage(long initialFailureTime,
RemoteOperationRequest<?> request) |
RemoteOperationsExecutorProxy |
LazyLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) |
RemoteOperationsExecutorProxy |
RoundRobinLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) |
abstract RemoteOperationsExecutorProxy |
SpaceProxyLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) |
long |
RemoteOperationsExecutorsCluster.getRemainingTime(RemoteOperationRequest<?> request,
long initialFailureTime) |
protected <T extends RemoteOperationResult> ClusterRemoteOperationRouter.ExecutionStatus |
ClusterRemoteOperationRouter.processResult(RemoteOperationRequest<T> request,
T result,
Exception executionException) |
String |
RemoteOperationsExecutorProxy.toLogMessage(RemoteOperationRequest<?> request) |