ReliableAsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationReliableAsyncGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
int batchSize,
long intervalMilis,
int intervalOperations,
IAsyncHandlerProvider asyncHandlerProvider,
Collection<SyncReplicationSourceChannel> keeperSyncChannelsCollection,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata,
String tag) |
ReliableAsyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig,
IReplicationRouter replicationRouter,
IReplicationReliableAsyncGroupBacklog groupBacklog,
String myLookupName,
IReplicationOutFilter outFilter,
IReplicationThrottleControllerBuilder throttleController,
IAsyncHandlerProvider asyncHandlerProvider,
int syncChannelAsyncStateBatchSize,
long syncChannelIdleDelayMilis,
int asyncChannelBatchSize,
long asyncChannelInterval,
int asyncChannelIntervalOperations,
IReplicationSourceGroupStateListener stateListener) |
SourceDelegationReplicationReliableAsyncMediator(DynamicReliableAsyncSourceGroupConfigHolder groupConfigHolder,
IReplicationConnection sourceConnection,
IReplicationReliableAsyncGroupBacklog reliableAsyncGroupBacklog,
String sourceLookupName,
String myLookupName,
IReplicationRouter router,
IReplicationChannelDataFilterBuilder filterBuilder,
IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder) |