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

Class AbstractSyncSingleOriginReplicationTargetGroup

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

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

Direct Known Subclasses:

ReliableAsyncKeeperReplicationTargetGroup, SyncSingleOriginReplicationTargetGroup

public abstract class AbstractSyncSingleOriginReplicationTargetGroup
extends AbstractSyncReplicationTargetGroup

Field Summary

Fields

Modifier and Type	Field and Description
protected SyncReplicationTargetChannel	_activeChannel

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

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected AbstractReplicationTargetChannel	createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected void	validateConnectChannelImpl(String sourceMemberLookupName) Validate if can accept the channel request, no exception means this channel request can be accepted

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

createChannel, createProcessLog

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

Field Detail

_activeChannel

protected volatile SyncReplicationTargetChannel _activeChannel

Constructor Detail

AbstractSyncSingleOriginReplicationTargetGroup

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

Method Detail

validateConnectChannelImpl

protected void validateConnectChannelImpl(String sourceMemberLookupName)
                                   throws ReplicationSourceAlreadyAttachedException

Description copied from class: AbstractReplicationTargetGroup

Validate if can accept the channel request, no exception means this channel request can be accepted

Specified by:

validateConnectChannelImpl in class AbstractReplicationTargetGroup

Throws:

ReplicationSourceAlreadyAttachedException

createNewChannelImpl

protected AbstractReplicationTargetChannel createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails,
                                                                IReplicationMonitoredConnection sourceConnection,
                                                                IBacklogHandshakeRequest handshakeRequest,
                                                                IReplicationGroupHistory groupHistory)

Specified by:

createNewChannelImpl in class AbstractReplicationTargetGroup