software.amazon.jdbc.plugin.efm

Class MonitorImpl

java.lang.Object

software.amazon.jdbc.plugin.efm.MonitorImpl

All Implemented Interfaces:

java.lang.Runnable, Monitor

public class MonitorImpl
extends java.lang.Object
implements Monitor

This class uses a background thread to monitor a particular server with one or more active Connection.

Constructor Summary

Constructors

Constructor and Description
MonitorImpl(@NonNull PluginService pluginService, @NonNull HostSpec hostSpec, @NonNull java.util.Properties properties, long monitorDisposalTimeMillis, @NonNull MonitorThreadContainer threadContainer) Store the monitoring configuration for a connection.

Method Summary

Modifier and Type	Method and Description
void	clearContexts() Clear all MonitorConnectionContext associated with this Monitor instance.
boolean	isStopped() Whether this Monitor has stopped monitoring a particular server.
void	run()
protected void	sleep(long duration) Used to help with testing.
void	startMonitoring(MonitorConnectionContext context)
void	stopMonitoring(MonitorConnectionContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

MonitorImpl

public MonitorImpl(@NonNull PluginService pluginService,
                   @NonNull HostSpec hostSpec,
                   @NonNull java.util.Properties properties,
                   long monitorDisposalTimeMillis,
                   @NonNull MonitorThreadContainer threadContainer)

Store the monitoring configuration for a connection.

Parameters:

pluginService - A service for creating new connections.

hostSpec - The HostSpec of the server this MonitorImpl instance is monitoring.

properties - The Properties containing additional monitoring configuration.

monitorDisposalTimeMillis - Time in milliseconds before stopping the monitoring thread where there are no active connection to the server this MonitorImpl instance is monitoring.

threadContainer - A reference to the MonitorThreadContainer implementation that initialized this class.

Method Detail

startMonitoring

public void startMonitoring(MonitorConnectionContext context)

Specified by:

startMonitoring in interface Monitor

stopMonitoring

public void stopMonitoring(MonitorConnectionContext context)

Specified by:

stopMonitoring in interface Monitor

clearContexts

public void clearContexts()

Description copied from interface: Monitor

Clear all MonitorConnectionContext associated with this Monitor instance.

Specified by:

clearContexts in interface Monitor

run

public void run()

Specified by:

run in interface java.lang.Runnable

isStopped

public boolean isStopped()

Description copied from interface: Monitor

Whether this Monitor has stopped monitoring a particular server.

Specified by:

isStopped in interface Monitor

Returns:

true if the monitoring has stopped; false otherwise.

sleep

protected void sleep(long duration)
              throws java.lang.InterruptedException

Used to help with testing.

Throws:

java.lang.InterruptedException