public class

SQSModelFactory

extends Object
java.lang.Object
   ↳ org.mule.modules.sqs.util.SQSModelFactory

Summary

Public Methods
static List<ChangeMessageVisibilityBatchRequestEntry> getChangeMessageVisibilityBatchRequestEntries(List<ChangeMessageVisibilityBatchRequestEntry> receiptHandles)
static ChangeMessageVisibilityBatchResult getChangeMessageVisibilityBatchResult(List<ChangeMessageVisibilityBatchResultEntry> successful, List<BatchResultErrorEntry> failed)
static List<DeleteMessageBatchRequestEntry> getDeleteMessageBatchRequestEntries(List<DeleteMessageBatchRequestEntry> receiptHandles)
static DeleteMessageBatchResult getDeleteMessageBatchResult(List<DeleteMessageBatchResultEntry> successful, List<BatchResultErrorEntry> failed)
static Map<String, MessageAttributeValue> getMessageAttributes(Map<String, Object> messageAttributes)
static List<SendMessageBatchRequestEntry> getSendMessageBatchRequestEntries(List<SendMessageBatchRequestEntry> messages)
static SendMessageBatchResult getSendMessageBatchResult(List<SendMessageBatchResultEntry> successful, List<BatchResultErrorEntry> failed)
static SendMessageResult getSendMessageResult(String messageId, String md5OfMessageBody, String md5OfMessageAttributes)
static Map<String, Object> wrapMessageAttributes(Message message)
[Expand]
Inherited Methods
From class java.lang.Object

Public Methods

public static List<ChangeMessageVisibilityBatchRequestEntry> getChangeMessageVisibilityBatchRequestEntries (List<ChangeMessageVisibilityBatchRequestEntry> receiptHandles)

Parameters
receiptHandles
Throws
SQSConnectorException

public static ChangeMessageVisibilityBatchResult getChangeMessageVisibilityBatchResult (List<ChangeMessageVisibilityBatchResultEntry> successful, List<BatchResultErrorEntry> failed)

Parameters
successful
failed
Throws
SQSConnectorException

public static List<DeleteMessageBatchRequestEntry> getDeleteMessageBatchRequestEntries (List<DeleteMessageBatchRequestEntry> receiptHandles)

Parameters
receiptHandles
Throws
SQSConnectorException

public static DeleteMessageBatchResult getDeleteMessageBatchResult (List<DeleteMessageBatchResultEntry> successful, List<BatchResultErrorEntry> failed)

Parameters
successful
failed
Throws
SQSConnectorException

public static Map<String, MessageAttributeValue> getMessageAttributes (Map<String, Object> messageAttributes)

Parameters
messageAttributes
Throws
SQSConnectorException

public static List<SendMessageBatchRequestEntry> getSendMessageBatchRequestEntries (List<SendMessageBatchRequestEntry> messages)

Parameters
messages
Throws
SQSConnectorException

public static SendMessageBatchResult getSendMessageBatchResult (List<SendMessageBatchResultEntry> successful, List<BatchResultErrorEntry> failed)

Parameters
successful
failed
Throws
SQSConnectorException

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

Parameters
messageId
md5OfMessageBody
md5OfMessageAttributes
Throws
SQSConnectorException

public static Map<String, Object> wrapMessageAttributes (Message message)

Parameters
message