AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
int batchSize,
long intervalMilis,
int intervalOperations,
IAsyncHandlerProvider asyncHandlerProvider,
boolean autoStart,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata,
String tag,
boolean resetTarget) |
AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
int batchSize,
long intervalMilis,
int intervalOperations,
IAsyncHandlerProvider asyncHandlerProvider,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata,
String tag) |
AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
int batchSize,
long intervalMilis,
int intervalOperations,
IAsyncHandlerProvider asyncHandlerProvider,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata,
String tag,
boolean resetTarget) |
AsyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig,
IReplicationRouter replicationRouter,
IReplicationAsyncGroupBacklog groupBacklog,
String myLookupName,
IReplicationOutFilter outFilter,
int batchSize,
long intervalMilis,
int intervalOperations,
IAsyncHandlerProvider asyncProvider,
IReplicationSourceGroupStateListener stateListener) |