org.skyscreamer.nevado.jms.connector.amazonaws

Class PlainTextAmazonSQSConnector

java.lang.Object

org.skyscreamer.nevado.jms.connector.AbstractSQSConnector

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

org.skyscreamer.nevado.jms.connector.amazonaws.PlainTextAmazonSQSConnector

All Implemented Interfaces:

SQSConnector

public class PlainTextAmazonSQSConnector
extends AmazonAwsSQSConnector

Overrides the serialisation handling from AbstractSQSConnector so that raw text messages can be received/sent without wrapping.

Author:

qi.chen

Field Summary

Fields inherited from class org.skyscreamer.nevado.jms.connector.amazonaws.AmazonAwsSQSConnector

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
PlainTextAmazonSQSConnector(String awsAccessKey, String awsSecretKey, boolean isSecure, long receiveCheckIntervalMs)
PlainTextAmazonSQSConnector(String awsAccessKey, String awsSecretKey, boolean isSecure, long receiveCheckIntervalMs, boolean isAsync)

Method Summary

Methods

Modifier and Type	Method and Description
protected NevadoMessage	deserializeMessage(String serializedMessage) Deserializes the body of an SQS message into a NevadoMessage object.
protected String	serializeMessage(NevadoMessage message) Serialize a NevadoMessage object into the body of an SQS message into a bae64 string.

Methods inherited from class org.skyscreamer.nevado.jms.connector.amazonaws.AmazonAwsSQSConnector

convertSqsMessage, createTopic, deleteTopic, getAmazonSNS, getAmazonSQS, getSQSQueueImpl, getTopicARN, handleAWSException, listQueues, listTopics, sendSNSMessage, subscribe, test, unsubscribe

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PlainTextAmazonSQSConnector

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

PlainTextAmazonSQSConnector

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

Method Detail

serializeMessage

protected String serializeMessage(NevadoMessage message)
                           throws javax.jms.JMSException

Description copied from class: AbstractSQSConnector

Serialize a NevadoMessage object into the body of an SQS message into a bae64 string.

Overrides:

serializeMessage in class AbstractSQSConnector

Parameters:

message - A NevadoMessage object

Returns:

A string-serialized encoding of the message

Throws:

javax.jms.JMSException - Unable to serialize the message

deserializeMessage

protected NevadoMessage deserializeMessage(String serializedMessage)
                                    throws javax.jms.JMSException

Description copied from class: AbstractSQSConnector

Deserializes the body of an SQS message into a NevadoMessage object.

Overrides:

deserializeMessage in class AbstractSQSConnector

Parameters:

serializedMessage - String-serialized NevadoMessage

Returns:

A deserialized NevadoMessage object

Throws:

javax.jms.JMSException - Unable to deserializeFromString a single NevadoMessage object from the source