Package com.gigaspaces.internal.cluster.node.impl.groups.reliableasync

Class ReliableAsyncSingleOriginReplicationTargetGroup

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.groups.reliableasync.ReliableAsyncSingleOriginReplicationTargetGroup

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

public class ReliableAsyncSingleOriginReplicationTargetGroup
extends AbstractReplicationTargetGroup

Field Summary

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

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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.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 Details

ReliableAsyncSingleOriginReplicationTargetGroup

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

Method Details

createNewChannelImpl

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

Specified by:

createNewChannelImpl in class AbstractReplicationTargetGroup

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