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

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 com.gigaspaces.internal.cluster.node.impl.groups.sync.AbstractSyncSingleOriginReplicationTargetGroup

_activeChannel

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationTargetGroup

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

Constructor and 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 and Description
protected IReplicationSyncTargetProcessLog	createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.sync.AbstractSyncSingleOriginReplicationTargetGroup

createNewChannelImpl, validateConnectChannelImpl

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.sync.AbstractSyncReplicationTargetGroup

createChannel

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.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 java.lang.Object

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

Constructor Detail

ReliableAsyncKeeperReplicationTargetGroup

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

Method Detail

createProcessLog

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

Specified by:

createProcessLog in class AbstractSyncReplicationTargetGroup