org.qbroker.jms

Class QMFMessenger

java.lang.Object

org.qbroker.net.QMFRequester

org.qbroker.jms.QMFMessenger

All Implemented Interfaces:

Connector, Requester

public class QMFMessenger
extends QMFRequester

QMFMessenger connects to a QMF server and converts the JMS messages into QMF 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.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.net.QMFRequester

uri

Constructor Summary

Constructors

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

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 QMF request from each message.

Methods inherited from class org.qbroker.net.QMFRequester

getAllAttributes, getInfo, getResponse, getURI, getValue, getValues, initialize, isConnected, list, listAll, main, reconnect

Methods inherited from class java.lang.Object

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

Constructor Detail

QMFMessenger

public QMFMessenger(java.util.Map props)

Creates new QMFMessenger

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 QMF request from each message. After the creating a list of QMF requests, it sends each request to the QMF 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

close

public void close()

Specified by:

close in interface Connector

Overrides:

close in class QMFRequester