Package 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	Description
protected final RemoteOperationsExecutor	_executor
protected final RemoteOperationsExecutorProxy	_memberProxy

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

_logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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	getAnyAvailableCachedMember()
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 Details

_memberProxy

protected final RemoteOperationsExecutorProxy _memberProxy

_executor

protected final RemoteOperationsExecutor _executor

Constructor Details

EmbeddedRemoteOperationRouter

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

Method Details

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

getAnyAvailableCachedMember

public RemoteOperationsExecutorProxy getAnyAvailableCachedMember()

getAllAvailableMembers

public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

close

public void close()

getPartitionId

public int getPartitionId()

getName

public String getName()