public class ReliableAsyncKeeperReplicationTargetGroup extends AbstractSyncSingleOriginReplicationTargetGroup
_activeChannel
_channelCloseTimeout, _loggerReplica, _specificLogger
Constructor and Description |
---|
ReliableAsyncKeeperReplicationTargetGroup(TargetGroupConfig groupConfig,
IReplicationRouter replicationRouter,
IReplicationInFilter inFilter,
IReplicationReliableAsyncKeeperProcessLogBuilder processLogBuilder,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder,
IReplicationTargetGroupStateListener stateListener,
IReplicationChannelDataFilterBuilder filterBuilder,
IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder) |
Modifier and Type | Method and Description |
---|---|
protected IReplicationSyncTargetProcessLog |
createProcessLog(TargetGroupConfig groupConfig,
String sourceLookupName,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationGroupHistory groupHistory,
IReplicationConnection sourceConnection) |
createNewChannelImpl, validateConnectChannelImpl
createChannel
addSynchronizeState, close, closeChannel, connectChannel, dumpState, getChannel, getGroupConfig, getGroupName, getInFilter, getLastProcessTimeStamp, getReplicationInFacade, getReplicationRouter, getStateListener, isFiltered, logEvent, logGroupEvent, onChannelBacklogDropped, outputDescendingEvents, process, processBatch, processHandshakeIteration, processIdleStateData, processUnreliableOperation, setActive, setPassive, synchronizationDone
public ReliableAsyncKeeperReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationInFilter inFilter, IReplicationReliableAsyncKeeperProcessLogBuilder processLogBuilder, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder, IReplicationTargetGroupStateListener stateListener, IReplicationChannelDataFilterBuilder filterBuilder, IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)
protected IReplicationSyncTargetProcessLog createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection)
createProcessLog
in class AbstractSyncReplicationTargetGroup
Copyright © GigaSpaces.