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

Class SyncMultiOriginReplicationTargetGroup

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

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

public class SyncMultiOriginReplicationTargetGroup
extends AbstractSyncReplicationTargetGroup

IReplicationTargetGroup that supports only multiple active source that is replicating to it (i.e active active sync replication)

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
SyncMultiOriginReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationSyncProcessLogBuilder 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 IReplicationSyncTargetProcessLog	createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection)
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

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

SyncMultiOriginReplicationTargetGroup

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

Method Detail

createNewChannelImpl

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

Specified by:

createNewChannelImpl in class AbstractReplicationTargetGroup

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

createProcessLog

protected IReplicationSyncTargetProcessLog createProcessLog(TargetGroupConfig groupConfig,
                                                            String sourceLookupName,
                                                            IReplicationInFacade replicationInFacade,
                                                            IReplicationProcessLogExceptionHandler exceptionHandler,
                                                            IReplicationGroupHistory groupHistory,
                                                            IReplicationConnection sourceConnection)

Specified by:

createProcessLog in class AbstractSyncReplicationTargetGroup