MultiSourceProcessLogMultiParticipantPacket(IReplicationOrderedPacket packet,
IReplicationParticipantsMediator participantsMediator,
IReplicationParticipantsMetadata participantsMetadata) |
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) |
MultiSourceSingleFileReplicationInBatchContext(IPacketConsumedCallback packetConsumedCallback,
org.slf4j.Logger contextLogger,
int entireBatchSize,
IReplicationParticipantsMediator participantsMediator,
String sourceLookupName,
String groupName) |