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

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

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 com.gigaspaces.internal.cluster.node.impl.groups.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 java.lang.Object

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

Constructor Detail

AbstractSyncReplicationTargetGroup

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

Method Detail

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)