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

Class ReliableAsyncReplicationSourceChannel

java.lang.Object

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

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

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

All Implemented Interfaces:

IReplicationSourceChannel, IConnectionStateListener

public class ReliableAsyncReplicationSourceChannel
extends AsyncReplicationSourceChannel

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.groups.async.AsyncReplicationSourceChannel

AsyncReplicationSourceChannel.AsyncDispatcher

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceChannel

AbstractReplicationSourceChannel.ChannelState

Field Summary

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

_packetsPool, _specificLogger, _specificVerboseLogger, _statisticsCounter

Constructor Summary

Constructors

Constructor

Description

ReliableAsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationReliableAsyncGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, Collection<SyncReplicationSourceChannel> keeperSyncChannelsCollection, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget)

Method Summary

Modifier and Type	Method	Description
ReplicationStatistics.ReplicationOperatingMode	getChannelOpertingMode()
protected List<IReplicationOrderedPacket>	getPendingPackets()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.async.AsyncReplicationSourceChannel

closeImpl, execute, flushPendingReplication, getBatchSize, onActiveImpl, onAsyncReplicateErrorResult, onAsyncReplicateErrorResult, onDisconnectedImpl, start

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceChannel

beginSynchronizing, beginSynchronizing, close, dispatchBacklogDropped, dumpState, getChannelState, getConnection, getDataFilter, getGroupBacklog, getGroupName, getInconsistencyReason, getLastSampledTP, getMemberName, getMyLookupName, getPendingPackets, getSampleTPBefore, getStatistics, getTargetLogicalVersion, getTargetReplicationEndpointDetails, isActive, isClosed, isDataFiltered, isInconsistent, isSynchronizing, logEventInHistory, onConnected, onDisconnected, onDumpState, pingTarget, registerWith, replicate, replicate, replicateAsync, replicateAsync, replicateBatch, replicateBatchDelayed, replicateBatchDelayedAsync, sampleStatistics, signalSynchronizingDone, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated, wrapConnection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReliableAsyncReplicationSourceChannel

public ReliableAsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
 String groupName,
 String memberName,
 IReplicationRouter replicationRouter,
 IReplicationMonitoredConnection connection,
 IReplicationReliableAsyncGroupBacklog groupBacklog,
 IReplicationOutFilter outFilter,
 int batchSize,
 long intervalMilis,
 int intervalOperations,
 IAsyncHandlerProvider asyncHandlerProvider,
 Collection<SyncReplicationSourceChannel> keeperSyncChannelsCollection,
 IReplicationChannelDataFilter dataFilter,
 IReplicationSourceGroupStateListener stateListener,
 IReplicationGroupHistory groupHistory,
 ReplicationStatistics.ReplicationMode channelType,
 Object customBacklogMetadata,
 String tag,
 boolean resetTarget)

Method Details

getPendingPackets

protected List<IReplicationOrderedPacket> getPendingPackets()

Overrides:

getPendingPackets in class AsyncReplicationSourceChannel

getChannelOpertingMode

public ReplicationStatistics.ReplicationOperatingMode getChannelOpertingMode()

Overrides:

getChannelOpertingMode in class AsyncReplicationSourceChannel