Class SpacePartitionedClusterRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

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

com.gigaspaces.internal.client.spaceproxy.router.SpacePartitionedClusterRemoteOperationRouter

All Implemented Interfaces:

SpaceProxyRemoteOperationRouter, RemoteOperationRouter

public class SpacePartitionedClusterRemoteOperationRouter
extends PartitionedClusterRemoteOperationRouter
implements SpaceProxyRemoteOperationRouter

Since:

9.0.1

Author:

Niv Ingberg

Field Summary

Fields inherited from class AbstractRemoteOperationRouter

_logger

Constructor Summary

Constructors

Constructor	Description
SpacePartitionedClusterRemoteOperationRouter(String name, SpaceProxyRemoteOperationRouter[] partitions, boolean broadcastDisabled, RemoteOperationsExecutorsCluster partitionedCluster, SpaceClusterInfo clusterInfo, SpaceProxyImpl spaceProxy)

Method Summary

Modifier and Type	Method	Description
String	getActiveMemberName(int partitionId)
SpaceProxyRemoteOperationRouter	getPartitionRouter(int partitionId)
SpaceProxyImpl	getSpaceProxy()

Methods inherited from class PartitionedClusterRemoteOperationRouter

close, createFutureListener, execute, executeAsync, executeOneway, getAllAvailableMembers, getAnyActiveMember, getAnyAvailableCachedMember, getAnyAvailableMember, getClusterInfo, getLogger, getNextApproxDistributionPartitionId, getNextDistributionPartitionId, getNextPreciseDistributionPartitionId, getNumOfPartitions, getPartitions, setClusterInfo

Methods inherited from class AbstractRemoteOperationRouter

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

Methods inherited from class Object

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

Methods inherited from interface RemoteOperationRouter

close, createFutureListener, execute, executeAsync, executeOneway, getAllAvailableMembers, getAnyActiveMember, getAnyAvailableCachedMember, getAnyAvailableMember, getCachedMember

Constructor Details

SpacePartitionedClusterRemoteOperationRouter

public SpacePartitionedClusterRemoteOperationRouter(String name,
 SpaceProxyRemoteOperationRouter[] partitions,
 boolean broadcastDisabled,
 RemoteOperationsExecutorsCluster partitionedCluster,
 SpaceClusterInfo clusterInfo,
 SpaceProxyImpl spaceProxy)

Method Details

getPartitionRouter

public SpaceProxyRemoteOperationRouter getPartitionRouter(int partitionId)

Overrides:

getPartitionRouter in class PartitionedClusterRemoteOperationRouter

getActiveMemberName

public String getActiveMemberName(int partitionId)

Specified by:

getActiveMemberName in interface SpaceProxyRemoteOperationRouter

getSpaceProxy

public SpaceProxyImpl getSpaceProxy()