Class AbstractSyncReplicationTargetGroup

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

Direct Known Subclasses:

AbstractSyncSingleOriginReplicationTargetGroup, SyncMultiOriginReplicationTargetGroup

public abstract class AbstractSyncReplicationTargetGroup
extends AbstractReplicationTargetGroup

Field Summary

Fields inherited from class AbstractReplicationTargetGroup

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected SyncReplicationTargetChannel	createChannel(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected abstract IReplicationSyncTargetProcessLog	createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection)

Methods inherited from class AbstractReplicationTargetGroup

addSynchronizeState, close, closeChannel, connectChannel, createNewChannelImpl, dumpState, getChannel, getGroupConfig, getGroupName, getInFilter, getLastProcessTimeStamp, getReplicationInFacade, getReplicationRouter, getStateListener, isFiltered, logEvent, logGroupEvent, onChannelBacklogDropped, outputDescendingEvents, process, processBatch, processHandshakeIteration, processIdleStateData, processUnreliableOperation, setActive, setPassive, synchronizationDone, validateConnectChannelImpl

Methods inherited from class Object

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

Constructor Details

AbstractSyncReplicationTargetGroup

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

Method Details

createChannel

protected SyncReplicationTargetChannel createChannel(ReplicationEndpointDetails sourceEndpointDetails,
 IReplicationMonitoredConnection sourceConnection,
 IBacklogHandshakeRequest handshakeRequest,
 IReplicationGroupHistory groupHistory)

createProcessLog

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