bridg.sqs.core — bridg/sqs 0.2.5

Lightweight wrapper around SQS functionality to abstract away details for high-level SQS consumers.

aws-credentials clj

change-message-visibility clj

(change-message-visibility queue-url receipt-handle visibility-timeout)

Changes the visibility timeout of a specified message in a queue to a new value. The maximum allowed timeout value is 12 hours. Thus, you can't extend the timeout of a message in an existing queue to more than a total visibility timeout of 12 hours. For more information, see Visibility Timeout in the Amazon Simple Queue Service Developer Guide.

http://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ChangeMessageVisibility.html

consume! clj

(consume! queue-url)

Consumes a message from SQS using the receive-message API.

delete! clj

(delete! queue-url receipt-handle)

first-message-body clj

(first-message-body result)

Returns the body of the first message returned from SQS.

message-bodies clj

(message-bodies result)

Returns sequence of all bodies from the SQS result.

produce! clj

(produce! queue-url message-group-id message-body)

Produces a message to SQS using the send-message API.

MessageGroupId is similar to a partition. Only one message will be retrieved for a given message group id at a time.

Messages must be JSON (only XML, JSON and raw text are supported by SQS.)