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

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 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
SyncSingleOriginReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationSyncProcessLogBuilder processLogBuilder, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener stateListener)

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

SyncSingleOriginReplicationTargetGroup

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

Method Detail

createProcessLog

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

Specified by:

createProcessLog in class AbstractSyncReplicationTargetGroup