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

Class AsyncReplicationTargetChannel

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationInFilterCallback, IReplicationTargetChannel, IConnectionStateListener, IConnectivityCheckListener

public class AsyncReplicationTargetChannel
extends AbstractReplicationTargetChannel

Field Summary

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

_specificLogger, _specificVerboseLogger

Constructor Summary

Constructors

Constructor

Description

AsyncReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationAsyncTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory, boolean wasEverActive)

Method Summary

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

afterSuccessfulConnectivityCheck, close, dumpState, getLastProcessTimeStamp, getMyLookupName, getProcessLog, getSourceEndpointAddress, getSourceLookupName, getSourceUniqueId, invokeInFilter, isSourceAttached, logEventInHistory, onChannelBacklogDropped, onConnected, onDisconnected, onDumpState, performHandshake, process, processBatch, processHandshakeIteration, processIdleStateData

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncReplicationTargetChannel

public AsyncReplicationTargetChannel(TargetGroupConfig groupConfig,
 String myLookupName,
 Object myUniqueId,
 ReplicationEndpointDetails sourceEndpointDetails,
 IReplicationMonitoredConnection sourceConnection,
 String groupName,
 IReplicationAsyncTargetProcessLog processLog,
 IReplicationInFilter inFilter,
 IReplicationTargetGroupStateListener groupStateListener,
 IReplicationGroupHistory groupHistory,
 boolean wasEverActive)