| Modifier and Type | Method and Description | 
|---|---|
protected void | 
SpaceClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request,
                       RemoteOperationsExecutorProxy proxy,
                       ClusterRemoteOperationRouter.ExecutionStatus status)  | 
protected boolean | 
SpaceClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request,
                        RemoteOperationsExecutorProxy proxy)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RemoteOperationFutureListener.onOperationCompletion(RemoteOperationRequest<T> request,
                     RemoteOperationsExecutorProxy sourceProxy)  | 
| Modifier and Type | Method and Description | 
|---|---|
RemoteOperationsExecutorProxy | 
RemoteOperationRouter.getAnyActiveMember()  | 
RemoteOperationsExecutorProxy | 
RemoteOperationRouter.getAnyAvailableMember()  | 
RemoteOperationsExecutorProxy | 
AbstractRemoteOperationRouter.getCachedMember()  | 
RemoteOperationsExecutorProxy | 
RemoteOperationRouter.getCachedMember()  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
AbstractRemoteOperationRouter.logAfterExecute(RemoteOperationsExecutorProxy proxy,
               RemoteOperationRequest<?> request,
               RemoteOperationResult result,
               boolean oneway)  | 
protected void | 
AbstractRemoteOperationRouter.logAfterExecuteAsync(RemoteOperationsExecutorProxy proxy,
                    RemoteOperationRequest<?> request,
                    RemoteOperationResult result)  | 
protected void | 
AbstractRemoteOperationRouter.logAsyncExecutionFailure(RemoteOperationsExecutorProxy proxy,
                        RemoteOperationRequest<?> request,
                        Exception exception)  | 
protected void | 
AbstractRemoteOperationRouter.logBeforeExecute(RemoteOperationsExecutorProxy proxy,
                RemoteOperationRequest<?> request,
                boolean oneway)  | 
protected void | 
AbstractRemoteOperationRouter.logBeforeExecuteAsync(RemoteOperationsExecutorProxy proxy,
                     RemoteOperationRequest<?> request)  | 
protected void | 
AbstractRemoteOperationRouter.logExecutionFailure(RemoteOperationsExecutorProxy proxy,
                   RemoteOperationRequest<?> request,
                   Exception exception,
                   boolean oneway)  | 
protected void | 
AbstractRemoteOperationRouter.logInterruptedAsyncExecution(RemoteOperationsExecutorProxy proxy,
                            RemoteOperationRequest<?> request,
                            Exception exception)  | 
protected void | 
AbstractRemoteOperationRouter.logInterruptedExecution(RemoteOperationsExecutorProxy proxy,
                       RemoteOperationRequest<?> request,
                       Exception exception,
                       boolean oneway)  | 
protected void | 
AbstractRemoteOperationRouter.logUnexpectedAsyncExecution(RemoteOperationsExecutorProxy proxy,
                           RemoteOperationRequest<?> request,
                           Exception exception)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RemoteOperationsExecutorsCluster.add(RemoteOperationsExecutorProxy proxy)  | 
protected void | 
ClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request,
                       RemoteOperationsExecutorProxy proxy,
                       ClusterRemoteOperationRouter.ExecutionStatus status)  | 
protected boolean | 
ClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request,
                        RemoteOperationsExecutorProxy proxy)  | 
void | 
RemoteOperationsExecutorsCluster.disconnect(RemoteOperationsExecutorProxy proxy)  | 
RemoteOperationsExecutorProxy | 
SpaceProxyLoadBalancingStrategy.findActiveMember(RemoteOperationRequest<?> request,
                long initialFailureTime,
                RemoteOperationsExecutorProxy oldCandidate)  | 
RemoteOperationsExecutorProxy | 
SpaceProxyLoadBalancingStrategy.findActiveMemberUninterruptibly(RemoteOperationRequest<?> request,
                               long initialFailureTime,
                               RemoteOperationsExecutorProxy proxy)  | 
static boolean | 
RemoteOperationsExecutorProxy.isAvailable(RemoteOperationsExecutorProxy proxy,
           boolean activeOnly)  | 
void | 
SpaceProxyLoadBalancingStrategy.onMemberConnected(RemoteOperationsExecutorProxy connectedMember)  | 
void | 
RoundRobinLoadBalancingStrategy.onMemberConnected(RemoteOperationsExecutorProxy connectedMember)  | 
protected abstract void | 
SpaceProxyLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy)
This method MUST be called from within a synchronized block. 
 | 
protected void | 
LazyLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy)  | 
protected void | 
RoundRobinLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClusterRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)  | 
void | 
RemoteOperationsExecutorsCluster.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)  | 
| Constructor and Description | 
|---|
LazyLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster,
                         RemoteOperationsExecutorProxy defaultMember)  | 
MemberLocatorTask(String name,
                 RemoteOperationsExecutorProxy proxy,
                 boolean activeOnly,
                 boolean timeBased)  | 
RemoteOperationsExecutorsCluster(String name,
                                SpaceClusterInfo clusterInfo,
                                int partitionId,
                                Collection<String> members,
                                RemoteOperationsExecutorsClusterConfig config,
                                IAsyncHandlerProvider asyncHandlerProvider,
                                RemoteOperationsExecutorProxyLocator proxyLocator,
                                RemoteOperationsExecutorProxy defaultMember)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected RemoteOperationsExecutorProxy | 
EmbeddedRemoteOperationRouter._memberProxy  | 
| Modifier and Type | Method and Description | 
|---|---|
RemoteOperationsExecutorProxy | 
EmbeddedRemoteOperationRouter.getAnyActiveMember()  | 
RemoteOperationsExecutorProxy | 
EmbeddedRemoteOperationRouter.getAnyAvailableMember()  | 
RemoteOperationsExecutorProxy | 
EmbeddedRemoteOperationRouter.getCachedMember()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EmbeddedRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)  | 
| Constructor and Description | 
|---|
EmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy,
                             int partitionId,
                             String name,
                             Executor asyncExecutor)  | 
| Modifier and Type | Method and Description | 
|---|---|
RemoteOperationsExecutorProxy | 
PartitionedClusterRemoteOperationRouter.getAnyActiveMember()  | 
RemoteOperationsExecutorProxy | 
PartitionedClusterRemoteOperationRouter.getAnyAvailableMember()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PartitionedClusterRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)  | 
Copyright © GigaSpaces.