public class BroadcastOperationFutureListener<T extends RemoteOperationResult> extends RemoteOperationFutureListener<T>
_logger
Constructor and Description |
---|
BroadcastOperationFutureListener(RemoteOperationRequest<T> mainRequest,
AsyncFutureListener<Object> listener,
PartitionedClusterRemoteOperationRouter router,
boolean getResultOnCompletion) |
Modifier and Type | Method and Description |
---|---|
protected Object |
getResult(RemoteOperationRequest<T> request) |
int |
getStartPartitionId() |
protected boolean |
onOperationResultArrival(RemoteOperationRequest<T> partitionRequest) |
cancel, get, get, isCancelled, isDone, onOperationCompletion, setListener, waitForCompletion, waitForCompletion
public BroadcastOperationFutureListener(RemoteOperationRequest<T> mainRequest, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion)
protected boolean onOperationResultArrival(RemoteOperationRequest<T> partitionRequest)
onOperationResultArrival
in class RemoteOperationFutureListener<T extends RemoteOperationResult>
protected Object getResult(RemoteOperationRequest<T> request) throws Exception
getResult
in class RemoteOperationFutureListener<T extends RemoteOperationResult>
Exception
public int getStartPartitionId()
Copyright © GigaSpaces.