org.skyscreamer.nevado.jms.connector.amazonaws

Class AmazonAwsSQSConnector

java.lang.Object

org.skyscreamer.nevado.jms.connector.AbstractSQSConnector

org.skyscreamer.nevado.jms.connector.amazonaws.AmazonAwsSQSConnector

All Implemented Interfaces:

SQSConnector

Direct Known Subclasses:

PlainTextAmazonSQSConnector

public class AmazonAwsSQSConnector
extends AbstractSQSConnector

Connector for SQS-only implementation of the Nevado JMS driver.

Author:

Carter Page

Field Summary

Fields

Modifier and Type	Field and Description
static String	MESSAGE_ATTRIBUTE_APPROXIMATE_RECEIVE_COUNT

Fields inherited from class org.skyscreamer.nevado.jms.connector.AbstractSQSConnector

_log, AWS_ERROR_CODE_AUTHENTICATION

Constructor Summary

Constructors

Constructor and Description
AmazonAwsSQSConnector(String awsAccessKey, String awsSecretKey, boolean isSecure, long receiveCheckIntervalMs)
AmazonAwsSQSConnector(String awsAccessKey, String awsSecretKey, boolean isSecure, long receiveCheckIntervalMs, boolean isAsync)

Method Summary

Methods

Modifier and Type	Method and Description
protected NevadoMessage	convertSqsMessage(NevadoDestination destination, SQSMessage sqsMessage, boolean readOnly)
NevadoTopic	createTopic(String topicName)
void	deleteTopic(NevadoTopic topic)
com.amazonaws.services.sns.AmazonSNS	getAmazonSNS()
com.amazonaws.services.sqs.AmazonSQS	getAmazonSQS()
protected AmazonAwsSQSQueue	getSQSQueueImpl(NevadoQueue queue)
protected String	getTopicARN(NevadoTopic topic)
protected javax.jms.JMSException	handleAWSException(String message, com.amazonaws.AmazonClientException e)
Collection<NevadoQueue>	listQueues(String temporaryQueuePrefix)
Collection<NevadoTopic>	listTopics()
protected void	sendSNSMessage(NevadoTopic topic, String serializedMessage)
String	subscribe(NevadoTopic topic, NevadoQueue topicEndpoint)
void	test()
void	unsubscribe(NevadoTopic topic)

Methods inherited from class org.skyscreamer.nevado.jms.connector.AbstractSQSConnector

createQueue, deleteMessage, deleteQueue, deserializeMessage, getPolicy, getSQSQueue, isAsync, receiveMessage, receiveSQSMessage, resetMessage, sendMessage, sendMessages, sendSQSMessage, serializeMessage

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_ATTRIBUTE_APPROXIMATE_RECEIVE_COUNT

public static final String MESSAGE_ATTRIBUTE_APPROXIMATE_RECEIVE_COUNT

See Also:

Constant Field Values

Constructor Detail

AmazonAwsSQSConnector

public AmazonAwsSQSConnector(String awsAccessKey,
                     String awsSecretKey,
                     boolean isSecure,
                     long receiveCheckIntervalMs)

AmazonAwsSQSConnector

public AmazonAwsSQSConnector(String awsAccessKey,
                     String awsSecretKey,
                     boolean isSecure,
                     long receiveCheckIntervalMs,
                     boolean isAsync)

Method Detail

sendSNSMessage

protected void sendSNSMessage(NevadoTopic topic,
                  String serializedMessage)
                       throws javax.jms.JMSException

Specified by:

sendSNSMessage in class AbstractSQSConnector

Throws:

javax.jms.JMSException

getSQSQueueImpl

protected AmazonAwsSQSQueue getSQSQueueImpl(NevadoQueue queue)
                                     throws javax.jms.JMSException

Specified by:

getSQSQueueImpl in class AbstractSQSConnector

Throws:

javax.jms.JMSException

test

public void test()
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

listQueues

public Collection<NevadoQueue> listQueues(String temporaryQueuePrefix)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTopic

public NevadoTopic createTopic(String topicName)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

deleteTopic

public void deleteTopic(NevadoTopic topic)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

listTopics

public Collection<NevadoTopic> listTopics()
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

subscribe

public String subscribe(NevadoTopic topic,
               NevadoQueue topicEndpoint)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

unsubscribe

public void unsubscribe(NevadoTopic topic)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

convertSqsMessage

protected NevadoMessage convertSqsMessage(NevadoDestination destination,
                              SQSMessage sqsMessage,
                              boolean readOnly)
                                   throws javax.jms.JMSException

Overrides:

convertSqsMessage in class AbstractSQSConnector

Throws:

javax.jms.JMSException

getAmazonSQS

public com.amazonaws.services.sqs.AmazonSQS getAmazonSQS()

getAmazonSNS

public com.amazonaws.services.sns.AmazonSNS getAmazonSNS()

getTopicARN

protected String getTopicARN(NevadoTopic topic)
                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

handleAWSException

protected javax.jms.JMSException handleAWSException(String message,
                                        com.amazonaws.AmazonClientException e)