org.qbroker.jms

Class AWSMessenger

java.lang.Object

org.qbroker.jms.AWSMessenger

public class AWSMessenger
extends java.lang.Object

AWSMessenger connects to an AWS service and converts the JMS messages into AWS requests. Currently, it only supports the action of request.

Author:

yannanlu@yahoo.com

Constructor Summary

Constructors

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

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 AWS request from each message.
java.lang.String	getURI()
boolean	isConnected()

Methods inherited from class java.lang.Object

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

Constructor Detail

AWSMessenger

public AWSMessenger(java.util.Map props)

Creates new AWSRequester

Method Detail

display

public void display(XQueue xq)
             throws java.io.IOException,
                    javax.jms.JMSException,
                    TimeoutException

It listens to an XQueue for incoming JMS messages and extracts the AWS request from each message. After the creating a list of AWS requests, it sends each request to the AWS 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.

Throws:

java.io.IOException

javax.jms.JMSException

TimeoutException

getURI

public java.lang.String getURI()

isConnected

public boolean isConnected()

close

public void close()