org.qbroker.jms

Class JMSMonitor

java.lang.Object

org.qbroker.monitor.Monitor

org.qbroker.jms.JMSMonitor

All Implemented Interfaces:

MonitorAction, MonitorReport

public class JMSMonitor
extends Monitor

JMSMonitor monitors a JMS application by watching its log and its queue depth. It supports 4 modes: Q_RESET, Q_BROWSE, Q_REMOVE and Q_GET or Q_PUT. With Q_RESET, it queries the EnqCount and DeqCount on a WMQ queue with reset option. With Q_BROWSE, it tries to browse the first message and checks its JMSTimestamp and JMSMessageID for the change. With Q_REMOVE, it tries to get a message from the queue. With Q_GET or Q_PUT, it counts the messages logged into a log file while checking on the queue depth.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	Q_BROWSE
static int	Q_GET
static int	Q_NOAPPS
static int	Q_OK
static int	Q_PUT
static int	Q_REMOVE
static int	Q_RESET
static int	Q_SLOW
static int	Q_STUCK
static int	Q_UNKNOWN
static java.lang.String[]	qStatusText

Fields inherited from class org.qbroker.monitor.Monitor

actionCount, actionGroup, aPatternGroup, cachedSkip, category, dependencyGroup, description, disabledWithReport, exceptionCount, exceptionTolerance, FILE_SEPARATOR, formatText, keyList, maxPage, maxRetry, name, normalStep, pm, previousStatus, repeatPeriod, report, reportMode, reportName, resolution, serialNumber, site, skip, statsLogger, statusOffset, statusText, step, template, timeFormat, timeTemplate, tolerance, type, xPatternGroup

Fields inherited from interface org.qbroker.monitor.MonitorReport

DISABLED, EXCEPTION, NOSKIP, REPORT_CACHED, REPORT_CLUSTER, REPORT_FINAL, REPORT_FLOW, REPORT_LOCAL, REPORT_NODE, REPORT_NONE, REPORT_SHARED, SKIPPED

Constructor Summary

Constructors

Constructor and Description
JMSMonitor(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	checkpoint() returns the checkpoint Map for the action
void	destroy() closes and releases all opened resources
protected void	finalize()
java.util.Map<java.lang.String,java.lang.Object>	generateReport(long currentTime) generates a report on a monitored entity and returns it as a Map.
static void	main(java.lang.String[] args)
Event	performAction(int status, long currentTime, java.util.Map<java.lang.String,java.lang.Object> latest) examines the report on the monitored entity and reacts to it as an action
void	restoreFromCheckpoint(java.util.Map<java.lang.String,java.lang.Object> chkpt) restores the state of the action from the checkpoint Map

Methods inherited from class org.qbroker.monitor.Monitor

getName, getReportKeys, getReportMode, getReportName, getSkippingStatus, initTimeTemplate, updateContent

Methods inherited from class java.lang.Object

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

Field Detail

Q_SLOW

public static final int Q_SLOW

See Also:

Constant Field Values

Q_STUCK

public static final int Q_STUCK

See Also:

Constant Field Values

Q_NOAPPS

public static final int Q_NOAPPS

See Also:

Constant Field Values

Q_UNKNOWN

public static final int Q_UNKNOWN

See Also:

Constant Field Values

Q_OK

public static final int Q_OK

See Also:

Constant Field Values

Q_GET

public static final int Q_GET

See Also:

Constant Field Values

Q_PUT

public static final int Q_PUT

See Also:

Constant Field Values

Q_BROWSE

public static final int Q_BROWSE

See Also:

Constant Field Values

Q_RESET

public static final int Q_RESET

See Also:

Constant Field Values

Q_REMOVE

public static final int Q_REMOVE

See Also:

Constant Field Values

qStatusText

public static final java.lang.String[] qStatusText

Constructor Detail

JMSMonitor

public JMSMonitor(java.util.Map props)

Method Detail

generateReport

public java.util.Map<java.lang.String,java.lang.Object> generateReport(long currentTime)
                                                                throws java.io.IOException

Description copied from interface: MonitorReport

generates a report on a monitored entity and returns it as a Map. The report Map will be passed to the associated MonitorAction as an opaque object. The action object is supposed to know how to retrieve the information from the report Map.

Specified by:

generateReport in interface MonitorReport

Specified by:

generateReport in class Monitor

Throws:

java.io.IOException

performAction

public Event performAction(int status,
                           long currentTime,
                           java.util.Map<java.lang.String,java.lang.Object> latest)

Description copied from interface: MonitorAction

examines the report on the monitored entity and reacts to it as an action

Specified by:

performAction in interface MonitorAction

Specified by:

performAction in class Monitor

checkpoint

public java.util.Map<java.lang.String,java.lang.Object> checkpoint()

Description copied from interface: MonitorAction

returns the checkpoint Map for the action

Specified by:

checkpoint in interface MonitorAction

Overrides:

checkpoint in class Monitor

restoreFromCheckpoint

public void restoreFromCheckpoint(java.util.Map<java.lang.String,java.lang.Object> chkpt)

Description copied from interface: MonitorAction

restores the state of the action from the checkpoint Map

Specified by:

restoreFromCheckpoint in interface MonitorAction

Overrides:

restoreFromCheckpoint in class Monitor

destroy

public void destroy()

Description copied from interface: MonitorReport

closes and releases all opened resources

Specified by:

destroy in interface MonitorReport

Overrides:

destroy in class Monitor

finalize

protected void finalize()

Overrides:

finalize in class Monitor

main

public static void main(java.lang.String[] args)