Package com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterReplicationScheduledPoolConnectionMonitor

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

com.gigaspaces.internal.cluster.node.impl.gateway.router.LusScheduledPoolConnectionMonitor

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationScheduledPoolConnectionMonitor

All Implemented Interfaces:

IConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

public class LocalClusterReplicationScheduledPoolConnectionMonitor
extends LusScheduledPoolConnectionMonitor

Since:

8.0.3

Author:

eitany

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor

AbstractScheduledPoolConnectionMonitor.MonitorConnectedConnectionTask

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor

_specificLogger, mayInterruptIfRunning

Constructor Summary

Constructors

Constructor	Description
LocalClusterReplicationScheduledPoolConnectionMonitor(String myLookupName, int corePoolSize, long monitorConnectedDelay, long monitorDisconnectedDelay, TimeUnit timeUnit, IReplicationLookupFinderService replicationLookupService)

Method Summary

Modifier and Type	Method	Description
protected IReplicationLookupResult	postConnectionEstablished(IReplicationLookupResult lookupResult, IReplicationLookupParameters lookupParameters, IReplicationRouter router)
protected IReplicationLookupParameters	prepareLookUpParameters(IReplicationLookupParameters lookupParameters)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.router.LusScheduledPoolConnectionMonitor

createMonitorDisconnectedTask

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor

close, dumpState, getLogPrefix, getMonitoredCount, monitor, stopMonitoring, updateDisconnected

Methods inherited from class java.lang.Object

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

Constructor Details

LocalClusterReplicationScheduledPoolConnectionMonitor

public LocalClusterReplicationScheduledPoolConnectionMonitor(String myLookupName,
 int corePoolSize,
 long monitorConnectedDelay,
 long monitorDisconnectedDelay,
 TimeUnit timeUnit,
 IReplicationLookupFinderService replicationLookupService)

Method Details

prepareLookUpParameters

protected IReplicationLookupParameters prepareLookUpParameters(IReplicationLookupParameters lookupParameters)

Overrides:

prepareLookUpParameters in class LusScheduledPoolConnectionMonitor

postConnectionEstablished

protected IReplicationLookupResult postConnectionEstablished(IReplicationLookupResult lookupResult,
 IReplicationLookupParameters lookupParameters,
 IReplicationRouter router)
                                                      throws RemoteException

Overrides:

postConnectionEstablished in class LusScheduledPoolConnectionMonitor

Throws:

RemoteException