com.gigaspaces.internal.remoting.routing.partitioned

Class CoordinatorFactory

java.lang.Object

com.gigaspaces.internal.remoting.routing.partitioned.CoordinatorFactory

public class CoordinatorFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
CoordinatorFactory()

Method Summary

Modifier and Type	Method and Description
<T extends RemoteOperationResult> BroadcastOperationFutureListener<T>	createAsyncBroadcastListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router)
<T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T>	createAsyncScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router)
protected <T extends RemoteOperationResult> BroadcastOperationFutureListener<T>	createBroadcastListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion)
protected <T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T>	createScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion)
<T extends RemoteOperationResult> BroadcastOperationFutureListener<T>	createSyncBroadcastListener(RemoteOperationRequest<T> request, PartitionedClusterRemoteOperationRouter router)
<T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T>	createSyncScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request, PartitionedClusterRemoteOperationRouter router)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatorFactory

public CoordinatorFactory()

Method Detail

createAsyncBroadcastListener

public <T extends RemoteOperationResult> BroadcastOperationFutureListener<T> createAsyncBroadcastListener(RemoteOperationRequest<T> request,
                                                                                                          AsyncFutureListener<Object> listener,
                                                                                                          PartitionedClusterRemoteOperationRouter router)

createSyncBroadcastListener

public <T extends RemoteOperationResult> BroadcastOperationFutureListener<T> createSyncBroadcastListener(RemoteOperationRequest<T> request,
                                                                                                         PartitionedClusterRemoteOperationRouter router)

createBroadcastListener

protected <T extends RemoteOperationResult> BroadcastOperationFutureListener<T> createBroadcastListener(RemoteOperationRequest<T> request,
                                                                                                        AsyncFutureListener<Object> listener,
                                                                                                        PartitionedClusterRemoteOperationRouter router,
                                                                                                        boolean getResultOnCompletion)

createAsyncScatterGatherListener

public <T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T> createAsyncScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request,
                                                                                                                  AsyncFutureListener<Object> listener,
                                                                                                                  PartitionedClusterRemoteOperationRouter router)

createSyncScatterGatherListener

public <T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T> createSyncScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request,
                                                                                                                 PartitionedClusterRemoteOperationRouter router)

createScatterGatherListener

protected <T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T> createScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request,
                                                                                                                AsyncFutureListener<Object> listener,
                                                                                                                PartitionedClusterRemoteOperationRouter router,
                                                                                                                boolean getResultOnCompletion)