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

Class AsyncSingleOriginReplicationTargetGroup

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.AsyncSingleOriginReplicationTargetGroup

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

public class AsyncSingleOriginReplicationTargetGroup
extends AbstractAsyncReplicationTargetGroup

Primary backup async target group

Since:

8.0

Author:

eitany

Field Summary

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

_channelCloseTimeout, _loggerReplica, _specificLogger

Constructor Summary

Constructors

Constructor and Description
AsyncSingleOriginReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationAsyncProcessLogBuilder processLogBuilder, 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 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 Detail

AsyncSingleOriginReplicationTargetGroup

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

Method Detail

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)
                                   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