com.gigaspaces.internal.client.spaceproxy.router

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 com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

_logger

Constructor Summary

Constructors

Constructor and Description
SpacePartitionedClusterRemoteOperationRouter(String name, SpaceProxyRemoteOperationRouter[] partitions, boolean broadcastDisabled, RemoteOperationsExecutorsCluster partitionedCluster)

Method Summary

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

Methods inherited from class com.gigaspaces.internal.remoting.routing.partitioned.PartitionedClusterRemoteOperationRouter

close, createFutureListener, execute, executeAsync, executeOneway, getAllAvailableMembers, getAnyActiveMember, getAnyAvailableMember, getLogger, getNextApproxDistributionPartitionId, getNextDistributionPartitionId, getNextPreciseDistributionPartitionId, getNumOfPartitions

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

Methods inherited from interface com.gigaspaces.internal.remoting.routing.RemoteOperationRouter

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

Constructor Detail

SpacePartitionedClusterRemoteOperationRouter

public SpacePartitionedClusterRemoteOperationRouter(String name,
                                                    SpaceProxyRemoteOperationRouter[] partitions,
                                                    boolean broadcastDisabled,
                                                    RemoteOperationsExecutorsCluster partitionedCluster)

Method Detail

getPartitionRouter

public SpaceProxyRemoteOperationRouter getPartitionRouter(int partitionId)

Overrides:

getPartitionRouter in class PartitionedClusterRemoteOperationRouter

getActiveMemberName

public String getActiveMemberName(int partitionId)

Specified by:

getActiveMemberName in interface SpaceProxyRemoteOperationRouter