Modifier and Type | Method and Description |
---|---|
IAsyncHandlerProvider |
SpaceProxyRouter.getAsyncHandlerProvider() |
Modifier and Type | Method and Description |
---|---|
IAsyncHandlerProvider |
IReplicationNodeBuilder.getAsyncHandlerProvider() |
IAsyncHandlerProvider |
ReplicationNodeBuilder.getAsyncHandlerProvider() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationNodeBuilder.setAsyncHandlerProvider(IAsyncHandlerProvider asyncHandlerProvider) |
Modifier and Type | Method and Description |
---|---|
IAsyncHandlerProvider |
AbstractReplicationSourceGroup.getAsyncHandlerProvider() |
Constructor and Description |
---|
AbstractReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
IAsyncHandlerProvider asyncHandlerProvider,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata,
String tag) |
AbstractReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfigHolder,
IReplicationRouter replicationRouter,
IReplicationGroupBacklog groupBacklog,
String myLookupName,
IReplicationOutFilter outFilter,
IAsyncHandlerProvider asyncHandlerProvider,
IReplicationSourceGroupStateListener stateListener) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncReplicationSourceGroupBuilder.setAsyncHandlerProvider(IAsyncHandlerProvider asyncHandlerProvider) |
Modifier and Type | Method and Description |
---|---|
void |
ReliableAsyncReplicationSourceGroupBuilder.setAsyncHandlerProvider(IAsyncHandlerProvider asyncHandlerProvider) |
Modifier and Type | Method and Description |
---|---|
void |
SyncReplicationSourceGroupBuilder.setAsyncHandlerProvider(IAsyncHandlerProvider asyncStateHandlerProvider) |
Constructor and Description |
---|
DurableNotificationLease(ReplicationNotificationClientEndpoint replicationNotificationClientEndpoint,
long lease,
EventSessionConfig sessionConfig,
IAsyncHandlerProvider asyncProvider) |
DurableNotificationReplicationNodeStateListener(EventSessionConfig config,
DurableNotificationLease lease,
IAsyncHandlerProvider asyncProvider,
SpaceClusterInfo clusterInfo,
int partitionId) |
Constructor and Description |
---|
RemoteOperationsExecutorsCluster(SpaceProxyImpl spaceProxy,
String name,
SpaceClusterInfo clusterInfo,
int partitionId,
Collection<String> members,
RemoteOperationsExecutorsClusterConfig config,
IAsyncHandlerProvider asyncHandlerProvider,
RemoteOperationsExecutorProxyLocator proxyLocator,
RemoteOperationsExecutorProxy defaultMember) |
RemoteOperationsExecutorsCluster(String name,
SpaceClusterInfo clusterInfo,
int partitionId,
Collection<String> members,
RemoteOperationsExecutorsClusterConfig config,
IAsyncHandlerProvider asyncHandlerProvider,
RemoteOperationsExecutorProxyLocator proxyLocator,
RemoteOperationsExecutorProxy defaultMember) |
RemoteOperationsExecutorsClustersMonitor(RemoteOperationsExecutorsCluster[] clusters,
IAsyncHandlerProvider asyncHandlerProvider) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAsyncHandlerProvider |
class |
ScheduledThreadPoolAsyncHandlerProvider
Scheduled thread pool based implementation for
IAsyncHandlerProvider |
static class |
SharedHandlerProviderCache.SharedAsyncHandlerProviderWrapper |
class |
ThreadAsyncHandlerProvider |
Modifier and Type | Method and Description |
---|---|
IAsyncHandlerProvider |
SharedHandlerProviderCache.IAsyncHandlerProviderFactory.createProvider(String name) |
IAsyncHandlerProvider |
SharedHandlerProviderCache.getProvider() |
Constructor and Description |
---|
CompetitionExecutor(IAsyncHandlerProvider asyncHandlerProvider) |
RepeatsCompetitionExecutor(T[] competitors,
int maxRepeats,
String name,
IAsyncHandlerProvider asyncHandlerProvider,
long idleDelay) |
TimedCompetitionExecutor(T[] competitors,
long timeout,
String name,
IAsyncHandlerProvider asyncHandlerProvider,
long idleDelay) |
Copyright © GigaSpaces.