Uses of Interface
com.gigaspaces.internal.cluster.node.impl.router.IReplicationMonitoredConnection

Packages that use IReplicationMonitoredConnection

Package	Description
com.gigaspaces.internal.cluster.node.impl.gateway.router
com.gigaspaces.internal.cluster.node.impl.gateway.sink
com.gigaspaces.internal.cluster.node.impl.groups
com.gigaspaces.internal.cluster.node.impl.groups.async
com.gigaspaces.internal.cluster.node.impl.groups.reliableasync
com.gigaspaces.internal.cluster.node.impl.groups.sync
com.gigaspaces.internal.cluster.node.impl.replica
com.gigaspaces.internal.cluster.node.impl.router
com.gigaspaces.internal.cluster.node.impl.router.spacefinder

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.gateway.router

Methods in com.gigaspaces.internal.cluster.node.impl.gateway.router that return IReplicationMonitoredConnection

Modifier and Type	Method	Description
IReplicationMonitoredConnection	UnifiedReplicationRouter.getDirectConnection(RouterStubHolder remoteStubHolder)
IReplicationMonitoredConnection	UnifiedReplicationRouter.getMemberConnection(String memberLookupName)
IReplicationMonitoredConnection	UnifiedReplicationRouter.getMemberConnectionAsync(String memberLookupName)
IReplicationMonitoredConnection	LusReplicationRouter.getUrlConnection(Object customUrl)
IReplicationMonitoredConnection	UnifiedReplicationRouter.getUrlConnection(Object customUrl)

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.gateway.sink

Methods in com.gigaspaces.internal.cluster.node.impl.gateway.sink that return IReplicationMonitoredConnection

Modifier and Type	Method	Description
IReplicationMonitoredConnection	LocalClusterReplicationSinkRouter.getUrlConnection(Object customUrl)

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.groups

Methods in com.gigaspaces.internal.cluster.node.impl.groups that return IReplicationMonitoredConnection

Modifier and Type	Method	Description
IReplicationMonitoredConnection	AbstractReplicationSourceChannel.getConnection()

Methods in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationMonitoredConnection

Modifier and Type	Method	Description
protected abstract AbstractReplicationSourceChannel	AbstractReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget)
protected abstract AbstractReplicationTargetChannel	AbstractReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationMonitoredConnection

Modifier	Constructor	Description
	AbstractReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag)
	AbstractReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget)
	AbstractReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory, boolean wasEverActive)

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.groups.async

Methods in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationMonitoredConnection

Modifier and Type	Method	Description
protected AsyncReplicationTargetChannel	AbstractAsyncReplicationTargetGroup.createChannel(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected AbstractReplicationSourceChannel	AsyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget)
protected AbstractReplicationTargetChannel	AsyncMultiOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected AbstractReplicationTargetChannel	AsyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationMonitoredConnection

Modifier	Constructor	Description
	AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, boolean autoStart, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget)
	AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag)
	AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget)
	AsyncReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationAsyncTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory, boolean wasEverActive)

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync

Methods in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationMonitoredConnection

Modifier and Type	Method	Description
protected AbstractReplicationSourceChannel	ReliableAsyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget)
protected AbstractReplicationTargetChannel	ReliableAsyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationMonitoredConnection

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

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.groups.sync

Methods in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationMonitoredConnection

Modifier and Type	Method	Description
protected SyncReplicationTargetChannel	AbstractSyncReplicationTargetGroup.createChannel(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected AbstractReplicationSourceChannel	SyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget)
protected AbstractReplicationTargetChannel	AbstractSyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
protected AbstractReplicationTargetChannel	SyncMultiOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationMonitoredConnection

Modifier	Constructor	Description
	SyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IReplicationThrottleController throttleController, IAsyncHandlerProvider asyncHandlerProvider, int asyncStateBatchSize, long idleDelayMilis, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata)
	SyncReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationSyncTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory)

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.replica

Constructors in com.gigaspaces.internal.cluster.node.impl.replica with parameters of type IReplicationMonitoredConnection

Modifier	Constructor	Description
	SpaceCopyReplicaRunnable(ReplicationNode replicationNode, IReplicationMonitoredConnection originConnection, ISpaceReplicaDataConsumer replicaDataProcessor, ISpaceCopyReplicaInFilter inFilter, Object replicaRemoteContext, int fetchBatchSize, SpaceReplicaState state, CyclicAtomicInteger orderProvider)
	SpaceReplicaState(IReplicationMonitoredConnection originConnection, boolean isSynchronize, long progressTimeout, IReplicationTargetGroup targetGroup)

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.router

Methods in com.gigaspaces.internal.cluster.node.impl.router that return IReplicationMonitoredConnection

Modifier and Type	Method	Description
protected IReplicationMonitoredConnection	AbstractConnectionProxyBasedReplicationRouter.createDirectConnection(String lookupName, boolean connectSynchronously)
IReplicationMonitoredConnection	AbstractConnectionProxyBasedReplicationRouter.getDirectConnection(RouterStubHolder remoteStubHolder)
IReplicationMonitoredConnection	IReplicationRouter.getDirectConnection(RouterStubHolder remoteStubHolder)	Gets a direct connection to the router represented by the given stub.
IReplicationMonitoredConnection	AbstractConnectionProxyBasedReplicationRouter.getMemberConnection(String lookupName)
IReplicationMonitoredConnection	IReplicationRouter.getMemberConnection(String memberLookupName)	Create new replication connection and establishes it.
IReplicationMonitoredConnection	AbstractConnectionProxyBasedReplicationRouter.getMemberConnectionAsync(String lookupName)
IReplicationMonitoredConnection	IReplicationRouter.getMemberConnectionAsync(String memberLookupName)	Gets a replication connection to a designated replication node by its name, the received connection is automatically managed by the router and it is in charge of detecting disconnection and reestablish connection when available.
IReplicationMonitoredConnection	DirectOnlyReplicationRouter.getUrlConnection(Object customUrl)
IReplicationMonitoredConnection	IReplicationRouter.getUrlConnection(Object customUrl)	Gets a connection with given custom url, need to have this due to space copy with given url which may not even reside in the cluster policy and for sink recovery

Uses of IReplicationMonitoredConnection in com.gigaspaces.internal.cluster.node.impl.router.spacefinder

Classes in com.gigaspaces.internal.cluster.node.impl.router.spacefinder that implement IReplicationMonitoredConnection

Modifier and Type	Class	Description
class	ConnectionReference<T,L>

Methods in com.gigaspaces.internal.cluster.node.impl.router.spacefinder that return IReplicationMonitoredConnection

Modifier and Type	Method	Description
IReplicationMonitoredConnection	SpaceProxyReplicationRouter.getUrlConnection(Object customUrl)