org.skyscreamer.nevado.jms.connector.amazonaws

Class AmazonAwsSQSQueue

java.lang.Object

org.skyscreamer.nevado.jms.connector.amazonaws.AmazonAwsSQSQueue

All Implemented Interfaces:

SQSQueue

public class AmazonAwsSQSQueue
extends Object
implements SQSQueue

Representation of an AmazonAWS queue

Author:

Carter Page

Field Summary

Fields

Modifier and Type	Field and Description
static String	ATTRIBUTE_POLICY
static String	ATTRIBUTE_QUEUE_ARN

Constructor Summary

Constructors

Constructor and Description
AmazonAwsSQSQueue(AmazonAwsSQSConnector amazonAwsSQSConnector, String queueUrl)
AmazonAwsSQSQueue(AmazonAwsSQSConnector amazonAwsSQSConnector, String queueUrl, boolean isAsync)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteMessage(String sqsReceiptHandle)
void	deleteQueue()
String	getQueueARN()
AmazonAwsSQSMessage	receiveMessage()
String	sendMessage(String serializedMessage)
void	setMessageVisibilityTimeout(String sqsReceiptHandle, int timeout)
void	setPolicy(String policy)

Methods inherited from class java.lang.Object

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

Field Detail

ATTRIBUTE_QUEUE_ARN

public static final String ATTRIBUTE_QUEUE_ARN

See Also:

Constant Field Values

ATTRIBUTE_POLICY

public static final String ATTRIBUTE_POLICY

See Also:

Constant Field Values

Constructor Detail

AmazonAwsSQSQueue

public AmazonAwsSQSQueue(AmazonAwsSQSConnector amazonAwsSQSConnector,
                 String queueUrl)

AmazonAwsSQSQueue

public AmazonAwsSQSQueue(AmazonAwsSQSConnector amazonAwsSQSConnector,
                 String queueUrl,
                 boolean isAsync)

Method Detail

sendMessage

public String sendMessage(String serializedMessage)
                   throws javax.jms.JMSException

Specified by:

sendMessage in interface SQSQueue

Throws:

javax.jms.JMSException

setMessageVisibilityTimeout

public void setMessageVisibilityTimeout(String sqsReceiptHandle,
                               int timeout)
                                 throws javax.jms.JMSException

Specified by:

setMessageVisibilityTimeout in interface SQSQueue

Throws:

javax.jms.JMSException

getQueueARN

public String getQueueARN()
                   throws javax.jms.JMSException

Specified by:

getQueueARN in interface SQSQueue

Throws:

javax.jms.JMSException

setPolicy

public void setPolicy(String policy)
               throws javax.jms.JMSException

Specified by:

setPolicy in interface SQSQueue

Throws:

javax.jms.JMSException

deleteMessage

public void deleteMessage(String sqsReceiptHandle)
                   throws javax.jms.JMSException

Specified by:

deleteMessage in interface SQSQueue

Throws:

javax.jms.JMSException

receiveMessage

public AmazonAwsSQSMessage receiveMessage()
                                   throws javax.jms.JMSException

Specified by:

receiveMessage in interface SQSQueue

Throws:

javax.jms.JMSException

deleteQueue

public void deleteQueue()
                 throws javax.jms.JMSException

Specified by:

deleteQueue in interface SQSQueue

Throws:

javax.jms.JMSException