Package | Description |
---|---|
org.mule.modules.sqs | |
org.mule.modules.sqs.model | |
org.mule.modules.sqs.util |
Modifier and Type | Method and Description |
---|---|
void |
SQSConnector.addPermission(String label,
List<String> accountIds,
List<String> actions,
String queueUrl)
Adds a permission to this message queue.
|
void |
SQSConnector.changeMessageVisibility(String receiptHandle,
Integer visibilityTimeout,
String queueUrl)
Changes the visibility timeout of a specified message in a queue to a new value.
|
ChangeMessageVisibilityBatchResult |
SQSConnector.changeMessageVisibilityBatch(List<ChangeMessageVisibilityBatchRequestEntry> receiptHandles,
String queueUrl)
Changes the visibility timeout of multiple messages.
|
CreateQueueResult |
SQSConnector.createQueue(String queueName,
RegionEndpoint region,
Map<String,String> attributes)
Creates a new queue, or returns the URL of an existing one.
|
void |
SQSConnector.deleteMessage(String receiptHandle,
String queueUrl)
Deletes the message identified by message object on the queue this object represents.
|
DeleteMessageBatchResult |
SQSConnector.deleteMessageBatch(List<DeleteMessageBatchRequestEntry> receiptHandles,
String queueUrl)
Deletes up to ten messages from the specified queue.
|
void |
SQSConnector.deleteQueue(String queueUrl)
Deletes the message queue represented by this object.
|
int |
SQSConnector.getApproximateNumberOfMessages(String queueUrl)
Gets an approximate number of visible messages for a queue.
|
GetQueueAttributesResult |
SQSConnector.getQueueAttributes(List<String> attributeNames,
String queueUrl)
Gets queue attributes.
|
GetQueueUrlResult |
SQSConnector.getQueueUrl(String queueName,
String queueOwnerAWSAccountId)
Returns the URL of an existing queue.
|
String |
Config.getUrl(String queueUrl) |
ListDeadLetterSourceQueuesResult |
SQSConnector.listDeadLetterSourceQueues(String queueUrl)
Returns a list of your queues that have the RedrivePolicy queue attribute configured with a dead letter queue.
|
ListQueuesResult |
SQSConnector.listQueues(String queueNamePrefix)
Returns a list of your queues.
|
void |
SQSConnector.purgeQueue(String queueUrl)
Deletes the messages in a queue specified by the queue URL.
|
void |
SQSConnector.receiveMessages(org.mule.api.callback.SourceCallback callback,
Integer visibilityTimeout,
Boolean preserveMessages,
Integer numberOfMessages,
String queueUrl)
Attempts to receive messages from a queue.
|
void |
SQSConnector.removePermission(String label,
String queueUrl)
Removes a permission from this message queue.
|
SendMessageResult |
SQSConnector.sendMessage(Message message,
String queueUrl)
Sends a message to a specified queue.
|
SendMessageBatchResult |
SQSConnector.sendMessageBatch(List<SendMessageBatchRequestEntry> messages,
String queueUrl)
Delivers up to ten messages to the specified queue.
|
void |
SQSConnector.setQueueAttributes(Map<String,String> attributes,
String queueUrl)
Sets the value of one or more queue attributes.
|
Modifier and Type | Class and Description |
---|---|
class |
SQSConnectionException
Exception thrown by the connector when we cannot resolve it to
ConnectionException |
Modifier and Type | Method and Description |
---|---|
static List<com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequestEntry> |
SQSModelFactory.getChangeMessageVisibilityBatchRequestEntries(List<ChangeMessageVisibilityBatchRequestEntry> receiptHandles) |
static ChangeMessageVisibilityBatchResult |
SQSModelFactory.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> |
SQSModelFactory.getDeleteMessageBatchRequestEntries(List<DeleteMessageBatchRequestEntry> receiptHandles) |
static DeleteMessageBatchResult |
SQSModelFactory.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> |
SQSModelFactory.getMessageAttributes(Map<String,MessageAttributeValue> messageAttributes) |
static List<com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry> |
SQSModelFactory.getSendMessageBatchRequestEntries(List<SendMessageBatchRequestEntry> messages) |
static SendMessageBatchResult |
SQSModelFactory.getSendMessageBatchResult(List<com.amazonaws.services.sqs.model.SendMessageBatchResultEntry> successful,
List<com.amazonaws.services.sqs.model.BatchResultErrorEntry> failed) |
static SendMessageResult |
SQSModelFactory.getSendMessageResult(String messageId,
String md5OfMessageBody,
String md5OfMessageAttributes) |
Copyright © 2010–2017. All rights reserved.