org.qbroker.wmq

Class PCFRequester

java.lang.Object

org.qbroker.wmq.PCFRequester

All Implemented Interfaces:

Connector, Requester

public class PCFRequester
extends java.lang.Object
implements Requester

PCFRequester connects to the admin service of a WebSphere MQ queue manager for PCF requests. Currently, it supports the method of display only. This is NOT MT-Safe due to IBM's implementation on sessions and conn.

Author:

yannanlu@yahoo.com

Constructor Summary

Constructors

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

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 PCF request from each message.
static java.lang.String	getCategory(java.lang.String cmd) returns the category of the target in the PCF command
static int	getCategoryID(java.lang.String category) returns the id of the category in the PCF command
int	getResponse(java.lang.String pcfCmd, java.lang.StringBuffer strBuf, boolean autoDisconn) This sends a request to the destination and returns the number of items filled in the given string buffer.
static java.lang.String	getTarget(java.lang.String cmd) returns the name of the target in the PCF command
static java.lang.String	getType(java.lang.String cmd) returns the type of the target in the PCF command
static int	getTypeID(int cid, java.lang.String type) returns the type id of the target in the PCF command
java.lang.String	getURI()
boolean	isConnected()
static void	main(java.lang.String[] args)
java.lang.String	reconnect() reconnects and returns null upon success or error msg otherwise

Methods inherited from class java.lang.Object

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

Constructor Detail

PCFRequester

public PCFRequester(java.util.Map props)

Creates new PCFRequester

Method Detail

reconnect

public java.lang.String reconnect()

reconnects and returns null upon success or error msg otherwise

Specified by:

reconnect in interface Connector

display

public void display(XQueue xq)
             throws javax.management.JMException,
                    TimeoutException

It listens to an XQueue for incoming JMS messages and extracts the PCF request from each message. After the creating a PCF Message for the request, it sends the message to the queue manager 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

TimeoutException

getResponse

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

This sends a 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.

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

getTypeID

public static int getTypeID(int cid,
                            java.lang.String type)

returns the type id of the target in the PCF command

getType

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

returns the type of the target in the PCF command

getCategoryID

public static int getCategoryID(java.lang.String category)

returns the id of the category in the PCF command

getCategory

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

returns the category of the target in the PCF command

getTarget

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

returns the name of the target in the PCF command

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

close

public void close()

Specified by:

close in interface Connector

main

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