org.qbroker.flow

Class GenericRequester

java.lang.Object

org.qbroker.flow.GenericRequester

All Implemented Interfaces:

Connector, Requester

public class GenericRequester
extends java.lang.Object
implements Requester

GenericRequester implements the API of Requester for various Persisters.

Author:

yannanlu@yahoo.com

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
int	getDataType() returns the expected dataType of responses
int	getResponse(java.lang.String request, java.lang.StringBuffer strBuf, boolean autoDisconn) This takes either an ad hoc message body or a generic query command as a request.
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

GenericRequester

public GenericRequester(java.util.Map props)

Method Detail

getResponse

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

This takes either an ad hoc message body or a generic query command as a request. First it converts the request into a JMS message. It sends the request message 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 alive.

By default, the request is not assumed to be a query command. If RequestCommand is defined, the request is assumed as a query command. A query command is supposed to be as follows:
ACTION Target Attributes

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

reconnect

public java.lang.String reconnect()

Description copied from interface: Connector

reconnects and returns null upon success or error msg otherwise

Specified by:

reconnect in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

getDataType

public int getDataType()

returns the expected dataType of responses

close

public void close()

Specified by:

close in interface Connector

main

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