MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
boolean oneWayMode,
IReplicationGroupHistory groupHistory,
IReplicationReliableAsyncMediator mediator) |
MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long lastProcessedKey,
boolean isFirstHandshake,
boolean oneWayMode,
IReplicationGroupHistory groupHistory,
IReplicationReliableAsyncMediator mediator) |
MultiSourceSingleFileReliableAsyncTargetProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig,
IReplicationPacketDataBatchConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory,
IReplicationParticipantsMediator participantsMediator,
IProcessMemoryManager processMemoryManager) |
MultiSourceSingleFileReliableAsyncTargetProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig,
IReplicationPacketDataBatchConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String myLookupName,
String groupName,
String sourceLookupName,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory,
IReplicationParticipantsMediator participantsMediator,
long lastProcessedKey,
long firstUnprocessedKey,
LinkedList<MultiSourceProcessLogPacket> pendingPacketsQueue,
HashMap<String,MultiSourceProcessLogPacket> packetsByUidHelperMap,
IProcessMemoryManager processMemoryManager) |