com.gigaspaces.internal.client.spaceproxy.router

Class SpaceClusterRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

com.gigaspaces.internal.remoting.routing.clustered.ClusterRemoteOperationRouter

com.gigaspaces.internal.client.spaceproxy.router.SpaceClusterRemoteOperationRouter

All Implemented Interfaces:

SpaceProxyRemoteOperationRouter, RemoteOperationRouter

public class SpaceClusterRemoteOperationRouter
extends ClusterRemoteOperationRouter
implements SpaceProxyRemoteOperationRouter

Since:

9.0

Author:

idan

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.remoting.routing.clustered.ClusterRemoteOperationRouter

ClusterRemoteOperationRouter.AsyncOperationExecutor<T extends RemoteOperationResult>, ClusterRemoteOperationRouter.ExecutionStatus

Field Summary

Fields inherited from class com.gigaspaces.internal.remoting.routing.clustered.ClusterRemoteOperationRouter

_cluster

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

_logger

Constructor Summary

Constructors

Constructor and Description
SpaceClusterRemoteOperationRouter(RemoteOperationsExecutorsCluster cluster, PostponedAsyncOperationsQueue postponedAsyncOperationsQueue, SpaceProxyImpl spaceProxy)

Method Summary

Modifier and Type	Method and Description
protected void	afterOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy, ClusterRemoteOperationRouter.ExecutionStatus status)
protected boolean	beforeOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy)
String	getActiveMemberName(int partitionId)

Methods inherited from class com.gigaspaces.internal.remoting.routing.clustered.ClusterRemoteOperationRouter

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

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

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

SpaceClusterRemoteOperationRouter

public SpaceClusterRemoteOperationRouter(RemoteOperationsExecutorsCluster cluster,
                                         PostponedAsyncOperationsQueue postponedAsyncOperationsQueue,
                                         SpaceProxyImpl spaceProxy)

Method Detail

beforeOperationExecution

protected boolean beforeOperationExecution(RemoteOperationRequest<?> request,
                                           RemoteOperationsExecutorProxy proxy)
                                    throws RemoteException

Overrides:

beforeOperationExecution in class ClusterRemoteOperationRouter

Throws:

RemoteException

afterOperationExecution

protected void afterOperationExecution(RemoteOperationRequest<?> request,
                                       RemoteOperationsExecutorProxy proxy,
                                       ClusterRemoteOperationRouter.ExecutionStatus status)

Overrides:

afterOperationExecution in class ClusterRemoteOperationRouter

getActiveMemberName

public String getActiveMemberName(int partitionId)

Specified by:

getActiveMemberName in interface SpaceProxyRemoteOperationRouter