public class PartitionedClusterRemoteOperationRouter extends AbstractRemoteOperationRouter
_logger| Constructor and Description |
|---|
PartitionedClusterRemoteOperationRouter(String name,
RemoteOperationRouter[] partitions,
CoordinatorFactory coordinatorFactory,
boolean broadcastDisabled,
int numberOfPerciseRoundRobingOperations,
RemoteOperationsExecutorsCluster partitionedCluster,
SpaceClusterInfo clusterInfo) |
getCachedMember, logAfterExecute, logAfterExecuteAsync, logAsyncExecutionFailure, logBeforeExecute, logBeforeExecuteAsync, logExecutionFailure, logInterruptedAsyncExecution, logInterruptedExecution, logUnexpectedAsyncExecutionpublic PartitionedClusterRemoteOperationRouter(String name, RemoteOperationRouter[] partitions, CoordinatorFactory coordinatorFactory, boolean broadcastDisabled, int numberOfPerciseRoundRobingOperations, RemoteOperationsExecutorsCluster partitionedCluster, SpaceClusterInfo clusterInfo)
public int getNumOfPartitions()
public RemoteOperationRouter[] getPartitions()
public SpaceClusterInfo getClusterInfo()
public void setClusterInfo(SpaceClusterInfo clusterInfo)
public RemoteOperationRouter getPartitionRouter(int partitionId)
public int getNextPreciseDistributionPartitionId(int groupingCode)
public int getNextApproxDistributionPartitionId()
public <T extends RemoteOperationResult> void execute(RemoteOperationRequest<T> request) throws InterruptedException
InterruptedExceptionpublic <T extends RemoteOperationResult> RemoteOperationFutureListener<T> createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener)
public <T extends RemoteOperationResult> void executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener)
public void executeOneway(RemoteOperationRequest<?> request) throws InterruptedException
InterruptedExceptionpublic int getNextDistributionPartitionId(RemoteOperationRequest<?> request)
public RemoteOperationsExecutorProxy getAnyAvailableMember()
public RemoteOperationsExecutorProxy getAnyAvailableCachedMember()
public RemoteOperationsExecutorProxy getAnyActiveMember()
public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)
public void close()
public org.slf4j.Logger getLogger()
Copyright © GigaSpaces.