AbstractMultiBucketSingleFileTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
AbstractMultiBucketSingleFileTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long[] lastProcessedKeys,
long[] lastGlobalProcessedKeys,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataBatchConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataBatchConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long lastGlobalProcessedKey,
long[] lastProcessedKeys,
long[] lastGlobalProcessedKeys,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory,
IReplicationReliableAsyncMediator mediator) |
MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long[] lastProcessedKeys,
long[] lastGlobalProcessedKeys,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory,
IReplicationReliableAsyncMediator mediator) |
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataBatchConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataBatchConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long lastGlobalProcessedKey,
long[] lastProcessedKeys,
long[] lastGlobalProcessedKeys,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long[] lastProcessedKeys,
long[] lastGlobalProcessedKeys,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory) |