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

Class AbstractAsyncReplicationTargetGroup

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

Direct Known Subclasses:

AsyncMultiOriginReplicationTargetGroup, AsyncSingleOriginReplicationTargetGroup

public abstract class AbstractAsyncReplicationTargetGroup
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
AbstractAsyncReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationAsyncProcessLogBuilder processLogBuilder, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener stateListener)

Method Summary

Modifier and Type	Method and Description
protected AsyncReplicationTargetChannel	createChannel(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected abstract IReplicationAsyncTargetProcessLog	createProcessLog(IReplicationAsyncProcessLogBuilder processLogBuilder, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)

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

AbstractAsyncReplicationTargetGroup

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

Method Detail

createChannel

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

createProcessLog

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