org.apache.streams.monitoring.tasks

Class BroadcastMonitorThread

java.lang.Object

javax.management.NotificationBroadcasterSupport

org.apache.streams.monitoring.tasks.BroadcastMonitorThread

All Implemented Interfaces:

Runnable, NotificationBroadcaster, NotificationEmitter

public class BroadcastMonitorThread
extends NotificationBroadcasterSupport
implements Runnable

This thread runs inside of a Streams runtime and periodically persists information from relevant JMX beans.

Constructor Summary

Constructors

Constructor and Description
BroadcastMonitorThread()
BroadcastMonitorThread(MonitoringConfiguration configuration) BroadcastMonitorThread constructor - uses supplied MonitoringConfiguration.

Method Summary

Modifier and Type	Method and Description
String	getBroadcastUri()
long	getWaitTime()
void	prepare() prepare for execution.
void	run() Get all relevant JMX beans, convert their values to strings, and then persist them.
void	shutdown()

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastMonitorThread

public BroadcastMonitorThread()

BroadcastMonitorThread

public BroadcastMonitorThread(MonitoringConfiguration configuration)

BroadcastMonitorThread constructor - uses supplied MonitoringConfiguration.

Parameters:

configuration - MonitoringConfiguration

Method Detail

run

public void run()

Get all relevant JMX beans, convert their values to strings, and then persist them.

Specified by:

run in interface Runnable

prepare

public void prepare()

prepare for execution.

shutdown

public void shutdown()

getBroadcastUri

public String getBroadcastUri()

getWaitTime

public long getWaitTime()