public class EmbeddedRemoteOperationRouter extends AbstractRemoteOperationRouter
| Modifier and Type | Field and Description |
|---|---|
protected RemoteOperationsExecutor |
_executor |
protected RemoteOperationsExecutorProxy |
_memberProxy |
_logger| Constructor and Description |
|---|
EmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy,
int partitionId,
String name,
Executor asyncExecutor) |
logAfterExecute, logAfterExecuteAsync, logAsyncExecutionFailure, logBeforeExecute, logBeforeExecuteAsync, logExecutionFailure, logInterruptedAsyncExecution, logInterruptedExecution, logUnexpectedAsyncExecutionprotected final RemoteOperationsExecutorProxy _memberProxy
protected final RemoteOperationsExecutor _executor
public EmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy, int partitionId, String name, Executor asyncExecutor)
public RemoteOperationsExecutor getExecutor()
public <T extends RemoteOperationResult> void execute(RemoteOperationRequest<T> request) throws InterruptedException
InterruptedExceptionprotected boolean beforeOperationExecution(RemoteOperationRequest<?> request)
protected void afterOperationExecution(RemoteOperationRequest<?> request)
public <T extends RemoteOperationResult> RemoteOperationFutureListener<T> createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener)
public <T extends RemoteOperationResult> void executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener)
public void executeOneway(RemoteOperationRequest<?> request) throws InterruptedException
InterruptedExceptionpublic RemoteOperationsExecutorProxy getCachedMember()
getCachedMember in interface RemoteOperationRoutergetCachedMember in class AbstractRemoteOperationRouterpublic RemoteOperationsExecutorProxy getAnyAvailableMember()
public RemoteOperationsExecutorProxy getAnyActiveMember()
public RemoteOperationsExecutorProxy getAnyAvailableCachedMember()
public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)
public void close()
public int getPartitionId()
public String getName()
Copyright © GigaSpaces.