org.qbroker.net

Class QMFRequester

java.lang.Object

org.qbroker.net.QMFRequester

All Implemented Interfaces:

Connector, Requester

Direct Known Subclasses:

QMFMessenger

public class QMFRequester
extends java.lang.Object
implements Requester

QMFRequester connects to a generic QMF server for QMF requests. Currently, it supports the methods of list, getValues and getResponse for QPid only.

It requires qpid-client.jar, qpid-common.jar, slf4-api.jar, slf4-log4j12,jar and Java 6 to compile.

Author:

yannanlu@yahoo.com

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
QMFRequester(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.String[]	getAllAttributes(java.lang.String target) returns names of all attributes for the target
java.util.Map<java.lang.String,java.util.List>	getInfo(java.lang.String target) returns a map with the info for the target
int	getResponse(java.lang.String qmfCmd, java.lang.StringBuffer strBuf, boolean autoDisconn) This takes a QMF query command and converts it into a QMF request.
java.lang.String	getURI()
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(java.lang.String target, java.lang.String[] attrs) returns the key-value map for the attributes from the target
protected javax.jms.ConnectionFactory	initialize()
boolean	isConnected()
java.lang.String[]	list(java.lang.String target) returns names of the all objects for the given class on the server
java.util.List<java.util.Map>	listAll(java.lang.String target, java.lang.String... attrs) returns a list of all objects for the given class 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

Constructor Detail

QMFRequester

public QMFRequester(java.util.Map props)

Method Detail

list

public java.lang.String[] list(java.lang.String target)
                        throws javax.jms.JMSException

returns names of the all objects for the given class on the server

Throws:

javax.jms.JMSException

listAll

public java.util.List<java.util.Map> listAll(java.lang.String target,
                                             java.lang.String... attrs)
                                      throws javax.jms.JMSException

returns a list of all objects for the given class on the server

Throws:

javax.jms.JMSException

getInfo

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

returns a map with the info for the target

Throws:

javax.jms.JMSException

getValue

public java.lang.Object getValue(java.lang.String target,
                                 java.lang.String attr)
                          throws javax.jms.JMSException

returns the value of the attribute from the target

Throws:

javax.jms.JMSException

getValues

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

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

Throws:

javax.jms.JMSException

getResponse

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

This takes a QMF query command and converts it into a QMF 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 QMF 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

getAllAttributes

public java.lang.String[] getAllAttributes(java.lang.String target)
                                    throws javax.jms.JMSException

returns names of all attributes for the target

Throws:

javax.jms.JMSException

initialize

protected javax.jms.ConnectionFactory initialize()
                                          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

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

main

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