Class SyncSingleOriginReplicationTargetGroup

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.sync.SyncSingleOriginReplicationTargetGroup

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

public class SyncSingleOriginReplicationTargetGroup
extends AbstractSyncSingleOriginReplicationTargetGroup

IReplicationTargetGroup that supports only one active source that is replicating to it (i.e primary backup topology, supports any number of backup)

Since:

8.0

Author:

eitany

Field Summary

Fields inherited from class AbstractSyncSingleOriginReplicationTargetGroup

_activeChannel

Fields inherited from class AbstractReplicationTargetGroup

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

Constructor	Description
SyncSingleOriginReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationSyncProcessLogBuilder processLogBuilder, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener stateListener)

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

SyncSingleOriginReplicationTargetGroup

public SyncSingleOriginReplicationTargetGroup(TargetGroupConfig groupConfig,
 IReplicationRouter replicationRouter,
 IReplicationSyncProcessLogBuilder processLogBuilder,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder,
 IReplicationInFilter inFilter,
 IReplicationTargetGroupStateListener stateListener)

Method Details

createProcessLog

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

Specified by:

createProcessLog in class AbstractSyncReplicationTargetGroup