org.qbroker.wmq

Class ChannelMonitor

java.lang.Object

org.qbroker.monitor.Monitor

org.qbroker.wmq.ChannelMonitor

All Implemented Interfaces:

MonitorAction, MonitorReport

public class ChannelMonitor
extends Monitor

ChannelMonitor monitors an MQSeries channel object for its stats and status Since it monitors the flow rate of the channel, it will disable itself at the start up for only once.

It supports SecurityExit in case it is required on the server side. You can specify the username and password if SecurityExit is defined.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	CH_ALL
static int	CH_BINDING
static int	CH_CLNTCONN
static int	CH_INACTIVE
static int	CH_INITIALIZING
static int	CH_NOAPPS
static int	CH_NOTFOUND
static int	CH_PAUSED
static int	CH_RECEIVER
static int	CH_REQUESTER
static int	CH_REQUESTING
static int	CH_RETRYING
static int	CH_RUNNING
static int	CH_SENDER
static int	CH_SERVER
static int	CH_STARTING
static int	CH_STOPPED
static int	CH_STOPPING
static int	CH_STUCK
static int	CH_SVRCONN
static int	CH_UNKNOWN
static int[]	chAttrs
static java.lang.String[]	chStatusText
static java.lang.String[]	chTypeText
static int	Q_KEEPOPEN
static int[]	qAttrs

Fields inherited from class org.qbroker.monitor.Monitor

actionCount, actionGroup, aPatternGroup, cachedSkip, category, dependencyGroup, description, disabledWithReport, disableMode, 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
ChannelMonitor(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
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

finalize, 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

chStatusText

public static final java.lang.String[] chStatusText

CH_STUCK

public static final int CH_STUCK

See Also:

Constant Field Values

CH_NOAPPS

public static final int CH_NOAPPS

See Also:

Constant Field Values

CH_UNKNOWN

public static final int CH_UNKNOWN

See Also:

Constant Field Values

CH_NOTFOUND

public static final int CH_NOTFOUND

See Also:

Constant Field Values

CH_INACTIVE

public static final int CH_INACTIVE

See Also:

Constant Field Values

CH_BINDING

public static final int CH_BINDING

See Also:

Constant Field Values

CH_STARTING

public static final int CH_STARTING

See Also:

Constant Field Values

CH_RUNNING

public static final int CH_RUNNING

See Also:

Constant Field Values

CH_STOPPING

public static final int CH_STOPPING

See Also:

Constant Field Values

CH_RETRYING

public static final int CH_RETRYING

See Also:

Constant Field Values

CH_STOPPED

public static final int CH_STOPPED

See Also:

Constant Field Values

CH_REQUESTING

public static final int CH_REQUESTING

See Also:

Constant Field Values

CH_PAUSED

public static final int CH_PAUSED

See Also:

Constant Field Values

CH_INITIALIZING

public static final int CH_INITIALIZING

See Also:

Constant Field Values

qAttrs

public static int[] qAttrs

chAttrs

public static int[] chAttrs

Q_KEEPOPEN

public static final int Q_KEEPOPEN

See Also:

Constant Field Values

CH_SENDER

public static final int CH_SENDER

See Also:

Constant Field Values

CH_SERVER

public static final int CH_SERVER

See Also:

Constant Field Values

CH_RECEIVER

public static final int CH_RECEIVER

See Also:

Constant Field Values

CH_REQUESTER

public static final int CH_REQUESTER

See Also:

Constant Field Values

CH_ALL

public static final int CH_ALL

See Also:

Constant Field Values

CH_CLNTCONN

public static final int CH_CLNTCONN

See Also:

Constant Field Values

CH_SVRCONN

public static final int CH_SVRCONN

See Also:

Constant Field Values

chTypeText

public static final java.lang.String[] chTypeText

Constructor Detail

ChannelMonitor

public ChannelMonitor(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

main

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