org.qbroker.jms

Class JMXMessenger

java.lang.Object

org.qbroker.jms.JMXMessenger

All Implemented Interfaces:

Connector

public class JMXMessenger
extends java.lang.Object
implements Connector

JMXMessenger connects to a JMX server and converts the JMS messages into JMX requests. The request retrieved from a message is supposed to be as follows:
ACTION Target attr0:attr1:attr2
where the colon delimitered attributes are optional. If there is no attribute defined, it will display all attributes if the target is not a pattern. In case the target contains at least one wildcard chars, * or ?, it will only list names of the MBeans. Currently, it only supports the action of display.

Author:

yannanlu@yahoo.com

Constructor Summary

Constructors

Constructor and Description
JMXMessenger(java.util.Map props) Creates new JMXMessenger

Method Summary

Modifier and Type	Method and Description
void	close()
void	display(XQueue xq) It listens to an XQueue for incoming JMS messages and extracts the JMX request from each message.
java.lang.String	getURI()
boolean	isConnected()
java.lang.String	reconnect() reconnects and returns null upon sucess or error msg otherwise

Methods inherited from class java.lang.Object

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

Constructor Detail

JMXMessenger

public JMXMessenger(java.util.Map props)

Creates new JMXMessenger

Method Detail

display

public void display(XQueue xq)
             throws javax.management.JMException,
                    javax.jms.JMSException,
                    TimeoutException

It listens to an XQueue for incoming JMS messages and extracts the JMX request from each message. After the creating a list of JMX requests, it sends each request to the JMX server as a query and waits for the response back. The response will be loaded into body of the request message according to the result type, similar to a DB qurey.

It also supports the dynamic content filter and the formatter on queried messages. The filter and the formatter are defined via a JSON text with Ruleset defined as a list. The JSON text is stored in the body of the request message. If the filter is defined, it will be used to select certain messages based on the content and the header. If the formatter is defined, it will be used to format the messages.

Throws:

javax.management.JMException

javax.jms.JMSException

TimeoutException

reconnect

public java.lang.String reconnect()

reconnects and returns null upon sucess or error msg otherwise

Specified by:

reconnect in interface Connector

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

close

public void close()

Specified by:

close in interface Connector