alma.acs.monitoring.blobber

Class BlobberPlugin

java.lang.Object

alma.acs.monitoring.blobber.BlobberPlugin

public abstract class BlobberPlugin
extends java.lang.Object

Provides code to the blobber which builds after ACS (somewhere in ARCHIVE/TMCDB/).

Field Summary

Fields

Modifier and Type	Field and Description
protected ContainerServices	containerServices
protected java.util.logging.Logger	logger

Constructor Summary

Constructors

Constructor and Description
BlobberPlugin(ContainerServices containerServices)

Method Summary

Modifier and Type	Method and Description
abstract void	cleanUp() Will be called by the blobber component as part of component cleanUp.
abstract BlobberWatchDog	getBlobberWatchDog()
abstract int	getCollectorIntervalSec() Gets the collector interval, possibly from class TMCDBConfig.
abstract java.util.List<MonitorDAO>	getMonitorDAOs() The entire DAO implementation is in ARCHIVE/TMCDB/DAO/ which is why we defer creation of alma.archive.tmcdb.DAO.MonitorDAOImpl or some mock implementation of the MonitorPointExpert interface to this plugin.
abstract MonitorPointExpert	getMonitorPointExpert()
abstract void	init() Will be called by the blobber component layer before calling getMonitorDAOs() or getBlobberWatchDog(), so that the plugin can create and install the DAOs and watchdog or do other initialization tasks.
abstract boolean	isProfilingEnabled() Reads profiling setting, possibly from class TMCDBConfig.

Methods inherited from class java.lang.Object

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

Field Detail

containerServices

protected final ContainerServices containerServices

logger

protected final java.util.logging.Logger logger

Constructor Detail

BlobberPlugin

public BlobberPlugin(ContainerServices containerServices)

Method Detail

isProfilingEnabled

public abstract boolean isProfilingEnabled()

Reads profiling setting, possibly from class TMCDBConfig.

getCollectorIntervalSec

public abstract int getCollectorIntervalSec()

Gets the collector interval, possibly from class TMCDBConfig.

Returns:

The interval in seconds for the blobber to read data from the monitor collectors.

init

public abstract void init()
                   throws AcsJCouldntCreateObjectEx

Will be called by the blobber component layer before calling getMonitorDAOs() or getBlobberWatchDog(), so that the plugin can create and install the DAOs and watchdog or do other initialization tasks.

Throws:

AcsJCouldntCreateObjectEx

See Also:

cleanUp()

cleanUp

public abstract void cleanUp()

Will be called by the blobber component as part of component cleanUp. The plugin should stop the DAOs, watchdog, and do other cleanup tasks.

See Also:

init()

getMonitorPointExpert

public abstract MonitorPointExpert getMonitorPointExpert()

getMonitorDAOs

public abstract java.util.List<MonitorDAO> getMonitorDAOs()

The entire DAO implementation is in ARCHIVE/TMCDB/DAO/ which is why we defer creation of alma.archive.tmcdb.DAO.MonitorDAOImpl or some mock implementation of the MonitorPointExpert interface to this plugin.

Normally only one DAO object should be returned, but for exceptional cases we support running several DAOs in parallel. This allows the Alma OSF to independently write the monitor data to the TMCDB and also stream it via activeMQ to files on a web server (a workaround which will be removed in the future).

The DAO object(s) must handle buffering and throwing away of data internally, so that the blobber component does not get stuck when calling the DAO layer.

getBlobberWatchDog

public abstract BlobberWatchDog getBlobberWatchDog()

Returns:

The watchdog object that also gets used by the DAO object(s).