Package com.gigaspaces.internal.remoting.routing

Interface RemoteOperationRouter

All Known Subinterfaces:

SpaceProxyRemoteOperationRouter

All Known Implementing Classes:

AbstractRemoteOperationRouter, ClusterRemoteOperationRouter, EmbeddedRemoteOperationRouter, PartitionedClusterRemoteOperationRouter, SpaceClusterRemoteOperationRouter, SpaceEmbeddedRemoteOperationRouter, SpacePartitionedClusterRemoteOperationRouter

public interface RemoteOperationRouter

Since:

9.0.1

Author:

Niv Ingberg

Method Summary

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

Method Details

execute

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

Throws:

InterruptedException

createFutureListener

<T extends RemoteOperationResult>
RemoteOperationFutureListener<T> createFutureListener(RemoteOperationRequest<T> request,
 AsyncFutureListener<Object> listener)

executeAsync

<T extends RemoteOperationResult> void executeAsync(RemoteOperationRequest<T> request,
 RemoteOperationFutureListener<T> futureListener)

executeOneway

void executeOneway(RemoteOperationRequest<?> request)
            throws InterruptedException

Throws:

InterruptedException

getCachedMember

RemoteOperationsExecutorProxy getCachedMember()

getAnyAvailableMember

RemoteOperationsExecutorProxy getAnyAvailableMember()

getAnyActiveMember

RemoteOperationsExecutorProxy getAnyActiveMember()

getAnyAvailableCachedMember

RemoteOperationsExecutorProxy getAnyAvailableCachedMember()

getAllAvailableMembers

void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

close

void close()