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 and Description
PartitionedClusterRemoteOperationRouter(String name, RemoteOperationRouter[] partitions, CoordinatorFactory coordinatorFactory, boolean broadcastDisabled, int numberOfPerciseRoundRobingOperations, RemoteOperationsExecutorsCluster partitionedCluster)

Method Summary

Modifier and Type	Method and 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	getAnyAvailableMember()
Logger	getLogger()
int	getNextApproxDistributionPartitionId()
int	getNextDistributionPartitionId(RemoteOperationRequest<?> request)
int	getNextPreciseDistributionPartitionId(int groupingCode)
int	getNumOfPartitions()
RemoteOperationRouter	getPartitionRouter(int partitionId)

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 Detail

PartitionedClusterRemoteOperationRouter

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

Method Detail

getNumOfPartitions

public int getNumOfPartitions()

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()

getAnyActiveMember

public RemoteOperationsExecutorProxy getAnyActiveMember()

getAllAvailableMembers

public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

close

public void close()

getLogger

public Logger getLogger()