org.qbroker.monitor

Class MonitorGroup

java.lang.Object

org.qbroker.monitor.MonitorGroup

public class MonitorGroup
extends java.lang.Object

MonitorGroup manages a group of monitors that can be used to monitor various monitors periodically. Each monitor contains three components, an MonitorReport object to generate the latest report on the monitor, an MonitorAction object to handle the monitor, and a set of time windows in which the monitor is expected to active. MonitorGroup also supports ConfigTemplate for a list of similar monitors. The method of reload() is to reload monitor properties dynamically.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FILE_SEPARATOR
static int	GROUP_CAPACITY
static int	TASK_COUNT
static int	TASK_GID
static int	TASK_ID
static int	TASK_RETRY
static int	TASK_SIZE
static int	TASK_STATUS
static int	TASK_TIME
static int	TASK_TYPE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.Map<java.lang.String,java.lang.Object>	diff(java.util.Map props) It returns a Map with only modified or new props.
int	dispatch(XQueue xq) It dispatches refreshed monitors to xq and returns total number of dispached monitor jobs
protected void	finalize()
int	getCapacity()
int	getDebugMode()
int	getHeartbeat()
int	getMaxRetry()
long	getMTime()
java.lang.String	getName()
static java.util.Map	getReport(java.lang.String rptName) returns the report map stored in the sharedReport on the rptName
int	getSize()
int	getTimeout()
static java.util.Map<java.lang.String,java.lang.Object>	initMonitor(java.util.Map ph, java.lang.String prefix) It initializes a monitor object with the given property map and returns a Map upon success or null otherwise.
boolean	isDynamic()
java.util.Map<java.lang.String,java.lang.String>	queryInfo(long currentTime, long sessionTime, java.lang.String target, java.lang.String key, int type) returns a Map containing queried information of the group according to the result type
int	reload(java.util.Map<java.lang.String,java.lang.Object> change) It reloads the changes for the entire group.
void	setDebugMode(int debug)
void	showChange(java.lang.String prefix, java.lang.String base, java.util.Map<java.lang.String,java.lang.Object> change, boolean detail) It loggs the details of the change returned by diff()

Methods inherited from class java.lang.Object

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

Field Detail

TASK_ID

public static final int TASK_ID

See Also:

Constant Field Values

TASK_GID

public static final int TASK_GID

See Also:

Constant Field Values

TASK_SIZE

public static final int TASK_SIZE

See Also:

Constant Field Values

TASK_TYPE

public static final int TASK_TYPE

See Also:

Constant Field Values

TASK_RETRY

public static final int TASK_RETRY

See Also:

Constant Field Values

TASK_STATUS

public static final int TASK_STATUS

See Also:

Constant Field Values

TASK_COUNT

public static final int TASK_COUNT

See Also:

Constant Field Values

TASK_TIME

public static final int TASK_TIME

See Also:

Constant Field Values

GROUP_CAPACITY

public static final int GROUP_CAPACITY

See Also:

Constant Field Values

FILE_SEPARATOR

public static final java.lang.String FILE_SEPARATOR

Constructor Detail

MonitorGroup

public MonitorGroup(java.util.Map props)

Method Detail

diff

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

It returns a Map with only modified or new props. The deleted items will be set to null in the returned Map. If the container has been changed, it will be reflected by the object keyed by base.

showChange

public void showChange(java.lang.String prefix,
                       java.lang.String base,
                       java.util.Map<java.lang.String,java.lang.Object> change,
                       boolean detail)

It loggs the details of the change returned by diff()

reload

public int reload(java.util.Map<java.lang.String,java.lang.Object> change)

It reloads the changes for the entire group.

dispatch

public int dispatch(XQueue xq)

It dispatches refreshed monitors to xq and returns total number of dispached monitor jobs

queryInfo

public java.util.Map<java.lang.String,java.lang.String> queryInfo(long currentTime,
                                                                  long sessionTime,
                                                                  java.lang.String target,
                                                                  java.lang.String key,
                                                                  int type)

returns a Map containing queried information of the group according to the result type

getName

public java.lang.String getName()

getSize

public int getSize()

getCapacity

public int getCapacity()

getHeartbeat

public int getHeartbeat()

getTimeout

public int getTimeout()

getMaxRetry

public int getMaxRetry()

getMTime

public long getMTime()

getDebugMode

public int getDebugMode()

setDebugMode

public void setDebugMode(int debug)

isDynamic

public boolean isDynamic()

close

public void close()

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object

initMonitor

public static java.util.Map<java.lang.String,java.lang.Object> initMonitor(java.util.Map ph,
                                                                           java.lang.String prefix)

It initializes a monitor object with the given property map and returns a Map upon success or null otherwise. If the monitor is successfully initialized but it has been disabled, an empty Map will be returned. Otherwise, the returned Map contains all the objects for the monitor.

getReport

public static java.util.Map getReport(java.lang.String rptName)

returns the report map stored in the sharedReport on the rptName