org.qbroker.persister

Class AWSRequester

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.AWSRequester

All Implemented Interfaces:

MessagePersister

public class AWSRequester
extends Persister

AWSRequester listens to an XQueue and receives JMS Messages from the XQueue as requests. It sends the requests to the given AWS service and waits for the responses. Then it loads the response to the incoming message and removes the message from XQueue so that the message is collectable by the nodes in upstream. AWSRequester supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.persister.Persister

capacity, displayMask, linkName, maxRetry, operation, partition, pauseTime, propertyName, repeatPeriod, standbyTime, status, timeout, tolerance, uri, waitTime, xaMode

Fields inherited from interface org.qbroker.persister.MessagePersister

PSTR_CLOSED, PSTR_DISABLED, PSTR_PAUSE, PSTR_READY, PSTR_RETRYING, PSTR_RUNNING, PSTR_STANDBY, PSTR_STOPPED

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
protected void	finalize()
void	persist(XQueue xq, int baseTime) implementation of persist() with flow control individual object control will be provided by the owner

Methods inherited from class org.qbroker.persister.Persister

getCapacity, getLinkName, getName, getOperation, getStatus, getXAMode, isStopped, keepRunning, resetStatus, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

AWSRequester

public AWSRequester(java.util.Map props)

Method Detail

persist

public void persist(XQueue xq,
                    int baseTime)

implementation of persist() with flow control individual object control will be provided by the owner

Specified by:

persist in interface MessagePersister

Specified by:

persist in class Persister

close

public void close()

Description copied from interface: MessagePersister

closes all opened resources

Specified by:

close in interface MessagePersister

Specified by:

close in class Persister

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object