com.gigaspaces.internal.remoting.routing.clustered

Class RemoteOperationsExecutorProxy

java.lang.Object

com.gigaspaces.internal.remoting.routing.clustered.RemoteOperationsExecutorProxy

public class RemoteOperationsExecutorProxy
extends Object

Since:

9.0.0

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
RemoteOperationsExecutorProxy(String name, RemoteOperationsExecutor executor, QuiesceTokenProvider quiesceTokenProvider)

Method Summary

Modifier and Type	Method and Description
void	close()
<T extends RemoteOperationResult> T	execute(RemoteOperationRequest<T> request)
<T extends RemoteOperationResult> void	executeAsync(RemoteOperationRequest<T> request, AsyncFutureListener<T> listener)
void	executeOneway(RemoteOperationRequest<?> request)
RemoteOperationsExecutor	getExecutor()
String	getName()
boolean	isActive()
boolean	isActiveQuiesceTokenAware()
static boolean	isAvailable(RemoteOperationsExecutorProxy proxy, boolean activeOnly)
String	toLogMessage(RemoteOperationRequest<?> request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RemoteOperationsExecutorProxy

public RemoteOperationsExecutorProxy(String name,
                                     RemoteOperationsExecutor executor,
                                     QuiesceTokenProvider quiesceTokenProvider)

Method Detail

getName

public String getName()

getExecutor

public RemoteOperationsExecutor getExecutor()

execute

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

Throws:

RemoteException

executeAsync

public <T extends RemoteOperationResult> void executeAsync(RemoteOperationRequest<T> request,
                                                           AsyncFutureListener<T> listener)
                                                    throws RemoteException

Throws:

RemoteException

executeOneway

public void executeOneway(RemoteOperationRequest<?> request)
                   throws RemoteException

Throws:

RemoteException

isActive

public boolean isActive()
                 throws RemoteException

Throws:

RemoteException

isActiveQuiesceTokenAware

public boolean isActiveQuiesceTokenAware()
                                  throws RemoteException

Throws:

RemoteException

toLogMessage

public String toLogMessage(RemoteOperationRequest<?> request)

close

public void close()

isAvailable

public static boolean isAvailable(RemoteOperationsExecutorProxy proxy,
                                  boolean activeOnly)