org.qbroker.sonicmq

Class SonicMQMessenger

java.lang.Object

org.qbroker.sonicmq.SonicMQRequester

org.qbroker.sonicmq.SonicMQMessenger

All Implemented Interfaces:

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

public class SonicMQMessenger
extends SonicMQRequester

SonicMQMessenger connects to a SonicMQ broker 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 delimited attributes are optional. If there is no attribute defined, it will display all attributes. Currently, it only supports the action of display and listen.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.sonicmq.SonicMQRequester

uri

Constructor Summary

Constructors

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

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.
void	listen(XQueue xq) It adds a notification listener to the SonicMQ broker and saves the XQueue instance as notice for the downstream.
void	onNotification(javax.management.Notification notification)

Methods inherited from class org.qbroker.sonicmq.SonicMQRequester

addListener, addListener, browse, compare, displayNotification, getAttributes, getInfo, getResponse, getURI, getValue, getValue, getValues, getValues, isConnected, list, main, query, reconnect, removeListener

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

Constructor Detail

SonicMQMessenger

public SonicMQMessenger(java.util.Map props)

Creates new SonicMQFMessenger

Method Detail

listen

public void listen(XQueue xq)
            throws javax.management.JMException

It adds a notification listener to the SonicMQ broker and saves the XQueue instance as notice for the downstream. The plugin method of onNotification converts the notifications into JMS TextMessages and puts them into notice. Since the method is called by the broker, it is passive or asynchronous in the nature. Therefore, it will ignore the actions of flow controls. In case the XQueue is on PAUSE state, the messages may still flow into it. Once the XQueue is full, the extra notifications will be dropped. So please set fairly large capacity for the XQueue of notice.

Throws:

javax.management.JMException

onNotification

public void onNotification(javax.management.Notification notification)

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 SonicMQ broker 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

close

public void close()

Specified by:

close in interface Connector

Overrides:

close in class SonicMQRequester