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

Class AsyncMultiOriginReplicationTargetGroup

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.groups.async.AbstractAsyncReplicationTargetGroup

com.gigaspaces.internal.cluster.node.impl.groups.async.AsyncMultiOriginReplicationTargetGroup

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

public class AsyncMultiOriginReplicationTargetGroup
extends AbstractAsyncReplicationTargetGroup

Field Summary

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

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

Constructor	Description
AsyncMultiOriginReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter router, IReplicationAsyncProcessLogBuilder processLogBuilder, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener stateListener)

Method Summary

Modifier and Type	Method	Description
protected AbstractReplicationTargetChannel	createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected IReplicationAsyncTargetProcessLog	createProcessLog(IReplicationAsyncProcessLogBuilder processLogBuilder, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, 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.async.AbstractAsyncReplicationTargetGroup

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 Details

AsyncMultiOriginReplicationTargetGroup

public AsyncMultiOriginReplicationTargetGroup(TargetGroupConfig groupConfig,
 IReplicationRouter router,
 IReplicationAsyncProcessLogBuilder processLogBuilder,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder,
 IReplicationInFilter inFilter,
 IReplicationTargetGroupStateListener stateListener)

Method Details

createNewChannelImpl

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

Specified by:

createNewChannelImpl in class AbstractReplicationTargetGroup

createProcessLog

protected IReplicationAsyncTargetProcessLog createProcessLog(IReplicationAsyncProcessLogBuilder processLogBuilder,
 String sourceLookupName,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IBacklogHandshakeRequest handshakeRequest,
 IReplicationGroupHistory groupHistory)

Specified by:

createProcessLog in class AbstractAsyncReplicationTargetGroup

validateConnectChannelImpl

protected void validateConnectChannelImpl(String sourceMemberLookupName)

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