Class ReliableAsyncKeeperReplicationTargetGroup

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationTargetGroup

com.gigaspaces.internal.cluster.node.impl.groups.sync.AbstractSyncReplicationTargetGroup

com.gigaspaces.internal.cluster.node.impl.groups.sync.AbstractSyncSingleOriginReplicationTargetGroup

com.gigaspaces.internal.cluster.node.impl.groups.reliableasync.ReliableAsyncKeeperReplicationTargetGroup

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

public class ReliableAsyncKeeperReplicationTargetGroup
extends AbstractSyncSingleOriginReplicationTargetGroup

Field Summary

Fields inherited from class AbstractSyncSingleOriginReplicationTargetGroup

_activeChannel

Fields inherited from class AbstractReplicationTargetGroup

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

Constructor

Description

ReliableAsyncKeeperReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationInFilter inFilter, IReplicationReliableAsyncKeeperProcessLogBuilder processLogBuilder, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder, IReplicationTargetGroupStateListener stateListener, IReplicationChannelDataFilterBuilder filterBuilder, IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)

Method Summary

Modifier and Type	Method	Description
protected IReplicationSyncTargetProcessLog	createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection)

Methods inherited from class AbstractSyncSingleOriginReplicationTargetGroup

createNewChannelImpl, validateConnectChannelImpl

Methods inherited from class AbstractSyncReplicationTargetGroup

createChannel

Methods inherited from class AbstractReplicationTargetGroup

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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReliableAsyncKeeperReplicationTargetGroup

public ReliableAsyncKeeperReplicationTargetGroup(TargetGroupConfig groupConfig,
 IReplicationRouter replicationRouter,
 IReplicationInFilter inFilter,
 IReplicationReliableAsyncKeeperProcessLogBuilder processLogBuilder,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder,
 IReplicationTargetGroupStateListener stateListener,
 IReplicationChannelDataFilterBuilder filterBuilder,
 IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)

Method Details

createProcessLog

protected IReplicationSyncTargetProcessLog createProcessLog(TargetGroupConfig groupConfig,
 String sourceLookupName,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationGroupHistory groupHistory,
 IReplicationConnection sourceConnection)

Specified by:

createProcessLog in class AbstractSyncReplicationTargetGroup