org.qbroker.sonicmq

Class SonicMQRequester

java.lang.Object

org.qbroker.sonicmq.SonicMQRequester

All Implemented Interfaces:

java.util.Comparator<com.sonicsw.mf.common.metrics.IMetric>, Connector, Requester

Direct Known Subclasses:

SonicMQMessenger

public class SonicMQRequester
extends java.lang.Object
implements Requester, java.util.Comparator<com.sonicsw.mf.common.metrics.IMetric>

SonicMQRequester connects to a SonicMQ broker for JMX requests. Currently, it supports the method of list, query, browse on durable subscriptions, addListener and removeListener.

Since ObjectName does not allow any key containing the char of ':', the replacement of ':' to '.' on subscription_id is assumed for queries as a workaround. It means you have to replace ':' with '.' in the query if the subscription_id is specified and it contains ':'.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	uri

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
javax.management.NotificationListener	addListener(java.lang.String target)
javax.management.NotificationListener	addListener(java.lang.String target, java.lang.String className, java.lang.String methodName, java.lang.Object obj) adds a listener with a filter for notifications to the target and waits for interruptions while listening on the filtered notifications
java.util.List<javax.jms.Message>	browse(java.lang.String target, int limit, boolean isLocal) returns a list of messages for a durable subscription or null
void	close()
int	compare(com.sonicsw.mf.common.metrics.IMetric a, com.sonicsw.mf.common.metrics.IMetric b)
static void	displayNotification(javax.management.Notification notification) displays the notification in details
static java.util.Map	getAttributes(javax.management.Notification notification)
java.util.Map<java.lang.String,java.util.List>	getInfo(java.lang.String target) returns an Map 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.
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, java.lang.String regex) returns names of the all MBeans for the given pattern on the server
static void	main(java.lang.String[] args)
java.util.List<java.util.Map>	query(java.lang.String target, java.lang.String regex)
java.lang.String	reconnect() returns null if reconnected or error msg otherwise
void	removeListener(javax.management.NotificationListener listener) removes the listener

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Comparator

comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Field Detail

uri

protected java.lang.String uri

Constructor Detail

SonicMQRequester

public SonicMQRequester(java.util.Map props)

Creates new SonicMQRequester

Method Detail

list

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

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

Throws:

javax.management.JMException

query

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

Throws:

javax.management.JMException

browse

public java.util.List<javax.jms.Message> browse(java.lang.String target,
                                                int limit,
                                                boolean isLocal)
                                         throws javax.management.JMException

returns a list of messages for a durable subscription or null

Throws:

javax.management.JMException

addListener

public javax.management.NotificationListener addListener(java.lang.String target)
                                                  throws javax.management.JMException

Throws:

javax.management.JMException

addListener

public javax.management.NotificationListener addListener(java.lang.String target,
                                                         java.lang.String className,
                                                         java.lang.String methodName,
                                                         java.lang.Object obj)
                                                  throws javax.management.JMException

adds a listener with a filter for notifications to the target and waits for interruptions while listening on the filtered notifications

Throws:

javax.management.JMException

removeListener

public void removeListener(javax.management.NotificationListener listener)

removes the listener

getInfo

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

returns an Map 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 command 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

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected 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

compare

public int compare(com.sonicsw.mf.common.metrics.IMetric a,
                   com.sonicsw.mf.common.metrics.IMetric b)

Specified by:

compare in interface java.util.Comparator<com.sonicsw.mf.common.metrics.IMetric>

displayNotification

public static void displayNotification(javax.management.Notification notification)

displays the notification in details

getAttributes

public static java.util.Map getAttributes(javax.management.Notification notification)

main

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