org.qbroker.net

Class JMXRequester

java.lang.Object

org.qbroker.net.JMXRequester

All Implemented Interfaces:

Connector, Requester

Direct Known Subclasses:

IMQRequester

public class JMXRequester
extends java.lang.Object
implements Requester

JMXRequester connects to a generic JMX server for JMX requests. Currently, it supports the methods of list, getValues and getResponse.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isConnected
protected javax.management.remote.JMXConnector	jmxc
protected java.lang.String	uri

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	connect()
java.lang.String[]	getAllAttributes(java.lang.String target) returns names of all attributes for the target
static java.lang.String	getAttributes(java.lang.String cmd) returns the attributes for the target in the JMX command
java.util.Map<java.lang.String,java.util.List>	getInfo(java.lang.String target) returns a hashmap with MBeanInfo for the target
int	getResponse(java.lang.String jmxCmd, java.lang.StringBuffer strBuf, boolean autoDisconn) This takes a JMX query command and converts it into a JMX request.
static java.lang.String	getTarget(java.lang.String cmd) returns the name of the target in the JMX command
java.lang.String	getURI()
java.lang.Object	getValue(javax.management.ObjectName objName, java.lang.String attr) returns the value of the attribute from the objName
java.lang.Object	getValue(java.lang.String target, java.lang.String attr) returns the value of the attribute from the target
java.util.Map<java.lang.String,java.lang.Object>	getValues(javax.management.ObjectName objName, java.lang.String[] attrs) returns the key-value map for the attributes from the objName
java.util.Map<java.lang.String,java.lang.Object>	getValues(java.lang.String target, java.lang.String[] attrs) returns the key-value map for the attributes from the target
boolean	isConnected()
java.lang.String[]	list(java.lang.String target) returns names of the all MBeans for the given pattern on the server
static void	main(java.lang.String[] args)
java.lang.String	reconnect() returns null if reconnected or error msg otherwise

Methods inherited from class java.lang.Object

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

Field Detail

uri

protected java.lang.String uri

jmxc

protected javax.management.remote.JMXConnector jmxc

isConnected

protected boolean isConnected

Constructor Detail

JMXRequester

public JMXRequester()

Creates new JMXRequester

JMXRequester

public JMXRequester(java.util.Map props)

Method Detail

list

public java.lang.String[] list(java.lang.String target)
                        throws javax.management.JMException

returns names of the all MBeans for the given pattern on the server

Throws:

javax.management.JMException

getInfo

public java.util.Map<java.lang.String,java.util.List> getInfo(java.lang.String target)
                                                       throws javax.management.JMException

returns a hashmap with MBeanInfo for the target

Throws:

javax.management.JMException

getValue

public java.lang.Object getValue(java.lang.String target,
                                 java.lang.String attr)
                          throws javax.management.JMException

returns the value of the attribute from the target

Throws:

javax.management.JMException

getValue

public java.lang.Object getValue(javax.management.ObjectName objName,
                                 java.lang.String attr)
                          throws javax.management.JMException

returns the value of the attribute from the objName

Throws:

javax.management.JMException

getValues

public java.util.Map<java.lang.String,java.lang.Object> getValues(java.lang.String target,
                                                                  java.lang.String[] attrs)
                                                           throws javax.management.JMException

returns the key-value map for the attributes from the target

Throws:

javax.management.JMException

getValues

public java.util.Map<java.lang.String,java.lang.Object> getValues(javax.management.ObjectName objName,
                                                                  java.lang.String[] attrs)
                                                           throws javax.management.JMException

returns the key-value map for the attributes from the objName

Throws:

javax.management.JMException

getResponse

public int getResponse(java.lang.String jmxCmd,
                       java.lang.StringBuffer strBuf,
                       boolean autoDisconn)
                throws WrapperException

This takes a JMX query command and converts it into a JMX request. It sends the request to the destination and returns the number of items filled in the given string buffer. The content in the string buffer is a JSON. If the disconnect flag is set to true, it disconnects right before it returns. Otherwise, it will keep the connection.

The JMX request is supposed to be as follows:
DISPLAY Target attr0:attr1:attr2

In case of a fatal failure, it disconnects first and then throws a WrapperException with cause set to the vendor specific exception or IO related exception. Therefore please make sure to get the cause exception from it and handles the cause exception with care. For other failures, it throws an IllegalArgumentException. If the disconnect flag is set to true, it disconnects right before it throws the exception.

Specified by:

getResponse in interface Requester

Throws:

WrapperException

connect

protected void connect()
                throws java.io.IOException

Throws:

java.io.IOException

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

reconnect

public java.lang.String reconnect()

returns null if reconnected or error msg otherwise

Specified by:

reconnect in interface Connector

close

public void close()

Specified by:

close in interface Connector

getTarget

public static java.lang.String getTarget(java.lang.String cmd)

returns the name of the target in the JMX command

getAttributes

public static java.lang.String getAttributes(java.lang.String cmd)

returns the attributes for the target in the JMX command

getAllAttributes

public java.lang.String[] getAllAttributes(java.lang.String target)
                                    throws javax.management.JMException

returns names of all attributes for the target

Throws:

javax.management.JMException

main

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