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

Class AbstractScheduledPoolConnectionMonitor<T,L>

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor<T,L>

All Implemented Interfaces:

IConnectionMonitor<T,L>

Direct Known Subclasses:

DirectConnectionScheduledPoolConnectionMonitor, LusScheduledPoolConnectionMonitor

public abstract class AbstractScheduledPoolConnectionMonitor<T,L>
extends Object
implements IConnectionMonitor<T,L>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AbstractScheduledPoolConnectionMonitor.MonitorConnectedConnectionTask

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	_specificLogger
boolean	mayInterruptIfRunning

Constructor Summary

Constructors

Constructor and Description
AbstractScheduledPoolConnectionMonitor(String myLookupName, int corePoolSize, long monitorConnectedDelay, long monitorDisconnectedDelay, TimeUnit timeUnit)

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract Runnable	createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)
String	dumpState()
protected String	getLogPrefix()
int	getMonitoredCount()
void	monitor(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection) Adds a new connection to monitor
void	stopMonitoring(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection) Stops monitoring the specified connection
void	updateDisconnected(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection, Exception reason) Update the monitor externally that the provided connection is disconnected Due to some call dispatch on that proxy which throw a remote exception

Methods inherited from class java.lang.Object

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

Field Detail

_specificLogger

protected final org.slf4j.Logger _specificLogger

mayInterruptIfRunning

public final boolean mayInterruptIfRunning

Constructor Detail

AbstractScheduledPoolConnectionMonitor

public AbstractScheduledPoolConnectionMonitor(String myLookupName,
                                              int corePoolSize,
                                              long monitorConnectedDelay,
                                              long monitorDisconnectedDelay,
                                              TimeUnit timeUnit)

Method Detail

getLogPrefix

protected String getLogPrefix()

monitor

public void monitor(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)

Description copied from interface: IConnectionMonitor

Adds a new connection to monitor

Specified by:

monitor in interface IConnectionMonitor<T,L>

Parameters:

connection - connection to monitor

createMonitorDisconnectedTask

protected abstract Runnable createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)

stopMonitoring

public void stopMonitoring(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)

Description copied from interface: IConnectionMonitor

Stops monitoring the specified connection

Specified by:

stopMonitoring in interface IConnectionMonitor<T,L>

Parameters:

connection - that should be not be monitored anymore

updateDisconnected

public void updateDisconnected(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection,
                               Exception reason)

Description copied from interface: IConnectionMonitor

Update the monitor externally that the provided connection is disconnected Due to some call dispatch on that proxy which throw a remote exception

Specified by:

updateDisconnected in interface IConnectionMonitor<T,L>

Parameters:

connection - connection that was disconnected

getMonitoredCount

public int getMonitoredCount()

close

public void close()

Specified by:

close in interface IConnectionMonitor<T,L>

dumpState

public String dumpState()

Specified by:

dumpState in interface IConnectionMonitor<T,L>