org.mule.modules.sqs.util

Class SQSModelFactory

java.lang.Object

org.mule.modules.sqs.util.SQSModelFactory

public class SQSModelFactory
extends Object

Method Summary

Modifier and Type	Method and Description
static List<com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequestEntry>	getChangeMessageVisibilityBatchRequestEntries(List<ChangeMessageVisibilityBatchRequestEntry> receiptHandles)
static ChangeMessageVisibilityBatchResult	getChangeMessageVisibilityBatchResult(List<com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchResultEntry> successful, List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed)
static List<com.amazonaws.services.sqs.model.DeleteMessageBatchRequestEntry>	getDeleteMessageBatchRequestEntries(List<DeleteMessageBatchRequestEntry> receiptHandles)
static DeleteMessageBatchResult	getDeleteMessageBatchResult(List<com.amazonaws.services.sqs.model.DeleteMessageBatchResultEntry> successful, List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed)
static Map<String,com.amazonaws.services.sqs.model.MessageAttributeValue>	getMessageAttributes(Map<String,MessageAttributeValue> messageAttributes)
static List<com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry>	getSendMessageBatchRequestEntries(List<SendMessageBatchRequestEntry> messages)
static SendMessageBatchResult	getSendMessageBatchResult(List<com.amazonaws.services.sqs.model.SendMessageBatchResultEntry> successful, List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed)
static SendMessageResult	getSendMessageResult(String messageId, String md5OfMessageBody, String md5OfMessageAttributes)
static Map<String,Object>	wrapMessageAttributes(com.amazonaws.services.sqs.model.Message message)

Methods inherited from class java.lang.Object

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

Method Detail

getChangeMessageVisibilityBatchResult

public static ChangeMessageVisibilityBatchResult getChangeMessageVisibilityBatchResult(List<com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchResultEntry> successful,
                                                                                       List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed)
                                                                                throws SQSConnectorException

Throws:

SQSConnectorException

getChangeMessageVisibilityBatchRequestEntries

public static List<com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequestEntry> getChangeMessageVisibilityBatchRequestEntries(List<ChangeMessageVisibilityBatchRequestEntry> receiptHandles)
                                                                                                                                     throws SQSConnectorException

Throws:

SQSConnectorException

getDeleteMessageBatchResult

public static DeleteMessageBatchResult getDeleteMessageBatchResult(List<com.amazonaws.services.sqs.model.DeleteMessageBatchResultEntry> successful,
                                                                   List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed)
                                                            throws SQSConnectorException

Throws:

SQSConnectorException

getDeleteMessageBatchRequestEntries

public static List<com.amazonaws.services.sqs.model.DeleteMessageBatchRequestEntry> getDeleteMessageBatchRequestEntries(List<DeleteMessageBatchRequestEntry> receiptHandles)
                                                                                                                 throws SQSConnectorException

Throws:

SQSConnectorException

getMessageAttributes

public static Map<String,com.amazonaws.services.sqs.model.MessageAttributeValue> getMessageAttributes(Map<String,MessageAttributeValue> messageAttributes)
                                                                                               throws SQSConnectorException

Throws:

SQSConnectorException

getSendMessageResult

public static SendMessageResult getSendMessageResult(String messageId,
                                                     String md5OfMessageBody,
                                                     String md5OfMessageAttributes)
                                              throws SQSConnectorException

Throws:

SQSConnectorException

getSendMessageBatchRequestEntries

public static List<com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry> getSendMessageBatchRequestEntries(List<SendMessageBatchRequestEntry> messages)
                                                                                                             throws SQSConnectorException

Throws:

SQSConnectorException

getSendMessageBatchResult

public static SendMessageBatchResult getSendMessageBatchResult(List<com.amazonaws.services.sqs.model.SendMessageBatchResultEntry> successful,
                                                               List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed)
                                                        throws SQSConnectorException

Throws:

SQSConnectorException

wrapMessageAttributes

public static Map<String,Object> wrapMessageAttributes(com.amazonaws.services.sqs.model.Message message)