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 AbstractScheduledPoolConnectionMonitor

AbstractScheduledPoolConnectionMonitor.MonitorConnectedConnectionTask

Field Summary

Fields inherited from class 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 LusScheduledPoolConnectionMonitor

createMonitorDisconnectedTask

Methods inherited from class AbstractScheduledPoolConnectionMonitor

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

Methods inherited from class 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