com.gigaspaces.internal.remoting.routing.partitioned

Class BroadcastOperationFutureListener<T extends RemoteOperationResult>

java.lang.Object

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

com.gigaspaces.internal.remoting.routing.partitioned.BroadcastOperationFutureListener<T>

All Implemented Interfaces:

AsyncFuture<Object>, Future<Object>

public class BroadcastOperationFutureListener<T extends RemoteOperationResult>
extends RemoteOperationFutureListener<T>

Since:

9.0.0

Author:

Niv Ingberg

Field Summary

Fields inherited from class com.gigaspaces.internal.remoting.RemoteOperationFutureListener

_logger

Constructor Summary

Constructors

Constructor and Description
BroadcastOperationFutureListener(RemoteOperationRequest<T> mainRequest, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion)

Method Summary

Modifier and Type	Method and Description
protected Object	getResult(RemoteOperationRequest<T> request)
int	getStartPartitionId()
protected boolean	onOperationResultArrival(RemoteOperationRequest<T> partitionRequest)

Methods inherited from class com.gigaspaces.internal.remoting.RemoteOperationFutureListener

cancel, get, get, isCancelled, isDone, onOperationCompletion, setListener, waitForCompletion, waitForCompletion

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastOperationFutureListener

public BroadcastOperationFutureListener(RemoteOperationRequest<T> mainRequest,
                                        AsyncFutureListener<Object> listener,
                                        PartitionedClusterRemoteOperationRouter router,
                                        boolean getResultOnCompletion)

Method Detail

onOperationResultArrival

protected boolean onOperationResultArrival(RemoteOperationRequest<T> partitionRequest)

Overrides:

onOperationResultArrival in class RemoteOperationFutureListener<T extends RemoteOperationResult>

getResult

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

Overrides:

getResult in class RemoteOperationFutureListener<T extends RemoteOperationResult>

Throws:

Exception

getStartPartitionId

public int getStartPartitionId()