Package com.gigaspaces.internal.remoting.routing.clustered

Class ClusterRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

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

All Implemented Interfaces:

RemoteOperationRouter

Direct Known Subclasses:

SpaceClusterRemoteOperationRouter

public class ClusterRemoteOperationRouter
extends AbstractRemoteOperationRouter

Since:

9.0.0

Author:

Niv Ingberg

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ClusterRemoteOperationRouter.AsyncOperationExecutor<T extends RemoteOperationResult>
protected static enum	ClusterRemoteOperationRouter.ExecutionStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected final RemoteOperationsExecutorsCluster	_cluster

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

_logger

Constructor Summary

Constructors

Constructor	Description
ClusterRemoteOperationRouter(RemoteOperationsExecutorsCluster cluster, PostponedAsyncOperationsQueue posponedAsyncOperationsQueue)

Method Summary

Modifier and Type	Method	Description
protected void	afterOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy, ClusterRemoteOperationRouter.ExecutionStatus status)
protected boolean	beforeOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy)
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()
RemoteOperationsExecutorProxy	getCachedMember()
protected <T extends RemoteOperationResult> ClusterRemoteOperationRouter.ExecutionStatus	processResult(RemoteOperationRequest<T> request, T result, Exception executionException)

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

Field Details

_cluster

protected final RemoteOperationsExecutorsCluster _cluster

Constructor Details

ClusterRemoteOperationRouter

public ClusterRemoteOperationRouter(RemoteOperationsExecutorsCluster cluster,
 PostponedAsyncOperationsQueue posponedAsyncOperationsQueue)

Method Details

execute

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

Throws:

InterruptedException

afterOperationExecution

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

processResult

protected <T extends RemoteOperationResult>
ClusterRemoteOperationRouter.ExecutionStatus processResult(RemoteOperationRequest<T> request,
 T result,
 Exception executionException)

beforeOperationExecution

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

Throws:

RemoteException

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

getCachedMember

public RemoteOperationsExecutorProxy getCachedMember()

Specified by:

getCachedMember in interface RemoteOperationRouter

Overrides:

getCachedMember in class AbstractRemoteOperationRouter

getAnyAvailableMember

public RemoteOperationsExecutorProxy getAnyAvailableMember()

getAnyAvailableCachedMember

public RemoteOperationsExecutorProxy getAnyAvailableCachedMember()

getAnyActiveMember

public RemoteOperationsExecutorProxy getAnyActiveMember()

getAllAvailableMembers

public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

close

public void close()