Package com.gigaspaces.internal.remoting.routing.partitioned

Class PartitionedClusterRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

com.gigaspaces.internal.remoting.routing.partitioned.PartitionedClusterRemoteOperationRouter

All Implemented Interfaces:

RemoteOperationRouter

Direct Known Subclasses:

SpacePartitionedClusterRemoteOperationRouter

public class PartitionedClusterRemoteOperationRouter
extends AbstractRemoteOperationRouter

Since:

9.0.0

Author:

Niv Ingberg

Field Summary

Fields inherited from class com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

_logger

Constructor Summary

Constructors

Constructor	Description
PartitionedClusterRemoteOperationRouter(String name, RemoteOperationRouter[] partitions, CoordinatorFactory coordinatorFactory, boolean broadcastDisabled, int numberOfPerciseRoundRobingOperations, RemoteOperationsExecutorsCluster partitionedCluster, SpaceClusterInfo clusterInfo)

Method Summary

Modifier and Type	Method	Description
void	close()
<T extends RemoteOperationResult> RemoteOperationFutureListener<T>	createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener)
<T extends RemoteOperationResult> void	execute(RemoteOperationRequest<T> request)
<T extends RemoteOperationResult> void	executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener)
void	executeOneway(RemoteOperationRequest<?> request)
void	getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)
RemoteOperationsExecutorProxy	getAnyActiveMember()
RemoteOperationsExecutorProxy	getAnyAvailableCachedMember()
RemoteOperationsExecutorProxy	getAnyAvailableMember()
SpaceClusterInfo	getClusterInfo()
org.slf4j.Logger	getLogger()
int	getNextApproxDistributionPartitionId()
int	getNextDistributionPartitionId(RemoteOperationRequest<?> request)
int	getNextPreciseDistributionPartitionId(int groupingCode)
int	getNumOfPartitions()
RemoteOperationRouter	getPartitionRouter(int partitionId)
RemoteOperationRouter[]	getPartitions()
void	setClusterInfo(SpaceClusterInfo clusterInfo)

Methods inherited from class com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

getCachedMember, logAfterExecute, logAfterExecuteAsync, logAsyncExecutionFailure, logBeforeExecute, logBeforeExecuteAsync, logExecutionFailure, logInterruptedAsyncExecution, logInterruptedExecution, logUnexpectedAsyncExecution

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionedClusterRemoteOperationRouter

public PartitionedClusterRemoteOperationRouter(String name,
 RemoteOperationRouter[] partitions,
 CoordinatorFactory coordinatorFactory,
 boolean broadcastDisabled,
 int numberOfPerciseRoundRobingOperations,
 RemoteOperationsExecutorsCluster partitionedCluster,
 SpaceClusterInfo clusterInfo)

Method Details

getNumOfPartitions

public int getNumOfPartitions()

getPartitions

public RemoteOperationRouter[] getPartitions()

getClusterInfo

public SpaceClusterInfo getClusterInfo()

setClusterInfo

public void setClusterInfo(SpaceClusterInfo clusterInfo)

getPartitionRouter

public RemoteOperationRouter getPartitionRouter(int partitionId)

getNextPreciseDistributionPartitionId

public int getNextPreciseDistributionPartitionId(int groupingCode)

getNextApproxDistributionPartitionId

public int getNextApproxDistributionPartitionId()

execute

public <T extends RemoteOperationResult> void execute(RemoteOperationRequest<T> request)
                                               throws InterruptedException

Throws:

InterruptedException

createFutureListener

public <T extends RemoteOperationResult>
RemoteOperationFutureListener<T> createFutureListener(RemoteOperationRequest<T> request,
 AsyncFutureListener<Object> listener)

executeAsync

public <T extends RemoteOperationResult> void executeAsync(RemoteOperationRequest<T> request,
 RemoteOperationFutureListener<T> futureListener)

executeOneway

public void executeOneway(RemoteOperationRequest<?> request)
                   throws InterruptedException

Throws:

InterruptedException

getNextDistributionPartitionId

public int getNextDistributionPartitionId(RemoteOperationRequest<?> request)

getAnyAvailableMember

public RemoteOperationsExecutorProxy getAnyAvailableMember()

getAnyAvailableCachedMember

public RemoteOperationsExecutorProxy getAnyAvailableCachedMember()

getAnyActiveMember

public RemoteOperationsExecutorProxy getAnyActiveMember()

getAllAvailableMembers

public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

close

public void close()

getLogger

public org.slf4j.Logger getLogger()