com.gigaspaces.internal.remoting

Class RemoteOperationFutureListener<T extends RemoteOperationResult>

java.lang.Object

com.gigaspaces.internal.remoting.RemoteOperationFutureListener<T>

All Implemented Interfaces:

AsyncFuture<Object>, Future<Object>

Direct Known Subclasses:

BroadcastOperationFutureListener, ScatterGatherOperationFutureListener

public class RemoteOperationFutureListener<T extends RemoteOperationResult>
extends Object
implements AsyncFuture<Object>

Since:

9.0.0

Author:

Niv Ingberg

Field Summary

Fields

Modifier and Type	Field and Description
protected Logger	_logger

Constructor Summary

Constructors

Constructor and Description
RemoteOperationFutureListener(Logger logger, AsyncFutureListener<Object> listener)
RemoteOperationFutureListener(Logger logger, AsyncFutureListener<Object> listener, boolean getResultOnCompletion)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
Object	get()
Object	get(long timeout, TimeUnit unit)
protected Object	getResult(RemoteOperationRequest<T> request)
boolean	isCancelled()
boolean	isDone()
void	onOperationCompletion(RemoteOperationRequest<T> request, RemoteOperationsExecutorProxy sourceProxy)
protected boolean	onOperationResultArrival(RemoteOperationRequest<T> request)
void	setListener(AsyncFutureListener<Object> listener)
void	waitForCompletion()
boolean	waitForCompletion(long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected final Logger _logger

Constructor Detail

RemoteOperationFutureListener

public RemoteOperationFutureListener(Logger logger,
                                     AsyncFutureListener<Object> listener)

RemoteOperationFutureListener

public RemoteOperationFutureListener(Logger logger,
                                     AsyncFutureListener<Object> listener,
                                     boolean getResultOnCompletion)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<Object>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<Object>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<Object>

get

public Object get()
           throws InterruptedException,
                  ExecutionException

Specified by:

get in interface Future<Object>

Throws:

InterruptedException

ExecutionException

get

public Object get(long timeout,
                  TimeUnit unit)
           throws InterruptedException,
                  TimeoutException,
                  ExecutionException

Specified by:

get in interface Future<Object>

Throws:

InterruptedException

TimeoutException

ExecutionException

setListener

public void setListener(AsyncFutureListener<Object> listener)

Specified by:

setListener in interface AsyncFuture<Object>

waitForCompletion

public void waitForCompletion()
                       throws InterruptedException

Throws:

InterruptedException

waitForCompletion

public boolean waitForCompletion(long timeout,
                                 TimeUnit unit)
                          throws InterruptedException

Throws:

InterruptedException

onOperationCompletion

public void onOperationCompletion(RemoteOperationRequest<T> request,
                                  RemoteOperationsExecutorProxy sourceProxy)

onOperationResultArrival

protected boolean onOperationResultArrival(RemoteOperationRequest<T> request)

getResult

protected Object getResult(RemoteOperationRequest<T> request)
                    throws Exception

Throws:

Exception