com.gigaspaces.internal.remoting.routing.embedded

Class EmbeddedRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

com.gigaspaces.internal.remoting.routing.embedded.EmbeddedRemoteOperationRouter

All Implemented Interfaces:

RemoteOperationRouter

Direct Known Subclasses:

SpaceEmbeddedRemoteOperationRouter

public class EmbeddedRemoteOperationRouter
extends AbstractRemoteOperationRouter

Since:

9.0.0

Author:

Niv Ingberg

Field Summary

Fields

Modifier and Type	Field and Description
protected RemoteOperationsExecutor	_executor
protected RemoteOperationsExecutorProxy	_memberProxy

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

_logger

Constructor Summary

Constructors

Constructor and Description
EmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy, int partitionId, String name, Executor asyncExecutor)

Method Summary

Modifier and Type	Method and Description
protected void	afterOperationExecution(RemoteOperationRequest<?> request)
protected boolean	beforeOperationExecution(RemoteOperationRequest<?> request)
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()
RemoteOperationsExecutorProxy	getCachedMember()
RemoteOperationsExecutor	getExecutor()
String	getName()
int	getPartitionId()

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 Detail

_memberProxy

protected final RemoteOperationsExecutorProxy _memberProxy

_executor

protected final RemoteOperationsExecutor _executor

Constructor Detail

EmbeddedRemoteOperationRouter

public EmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy,
                                     int partitionId,
                                     String name,
                                     Executor asyncExecutor)

Method Detail

getExecutor

public RemoteOperationsExecutor getExecutor()

execute

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

Throws:

InterruptedException

beforeOperationExecution

protected boolean beforeOperationExecution(RemoteOperationRequest<?> request)

afterOperationExecution

protected void afterOperationExecution(RemoteOperationRequest<?> request)

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

getAnyActiveMember

public RemoteOperationsExecutorProxy getAnyActiveMember()

getAllAvailableMembers

public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

close

public void close()

getPartitionId

public int getPartitionId()

getName

public String getName()