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

Class LusScheduledPoolConnectionMonitor

java.lang.Object

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

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

All Implemented Interfaces:

IConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

Direct Known Subclasses:

LocalClusterReplicationScheduledPoolConnectionMonitor

public class LusScheduledPoolConnectionMonitor
extends AbstractScheduledPoolConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

A base class for a connection monitor that uses a scheduled thread pool for its monitoring tasks

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 and Description
LusScheduledPoolConnectionMonitor(String myLookupName, int corePoolSize, long monitorConnectedDelay, long monitorDisconnectedDelay, TimeUnit timeUnit, IReplicationLookupFinderService replicationLookupService)

Method Summary

Modifier and Type	Method and Description
protected Runnable	createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> connection)
protected IReplicationLookupResult	postConnectionEstablished(IReplicationLookupResult lookupResult, IReplicationLookupParameters lookupParameters, IReplicationRouter router)
protected IReplicationLookupParameters	prepareLookUpParameters(IReplicationLookupParameters lookupParameters)

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 Detail

LusScheduledPoolConnectionMonitor

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

Method Detail

createMonitorDisconnectedTask

protected Runnable createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> connection)

Specified by:

createMonitorDisconnectedTask in class AbstractScheduledPoolConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

postConnectionEstablished

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

Throws:

RemoteException

prepareLookUpParameters

protected IReplicationLookupParameters prepareLookUpParameters(IReplicationLookupParameters lookupParameters)