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) |