com.climate.squeedo.sqs — com.climate/squeedo 1.1.1

ack clj

(ack {:keys [client queue-url]} {:keys [receipt-handle]})

Remove the message from the queue.

Input: connection - as created by mk-connection message - the message to ack

auto-retry-seconds clj

How long to wait before retrying a non-responding compute request.

configure-queue clj

(configure-queue queue-name
                 &
                 {:keys [client queue-attributes dead-letter
                         dead-letter-queue-attributes]})

Update an SQS queue with the provided configuration. This should be done once at startup time, when you need to (re)configure the queue.

The queue attribute maps must be from string to string, with keys matching standard SQS attribute names.

Optionally takes the name of a dead-letter queue, where messages that failed too many times will go. http://aws.typepad.com/aws/2014/01/amazon-sqs-new-dead-letter-queue.html

The queue will be created if it does not exist. A dead letter queue will be created if specified and it does not exist.

Input: queue-name - The name of the queue to be configured.

Optional arguments: :queue-attributes - attribute map for the main queue :dead-letter - name of dead letter queue :dead-letter-queue-attributes - attribute map for the dead letter queue

dequeue clj

(dequeue & args)

Read messages from a queue. If there is nothing to read before poll-timeout-seconds, return [].

This does not remove the messages from the queue! For that, see ack.

In case of exception, logs the exception and returns [].

dequeue* clj

(dequeue* {:keys [client queue-name queue-url]}
          &
          {:keys [limit attributes message-attributes]
           :or {limit 10 attributes #{"All"} message-attributes #{"All"}}})

Read messages from a queue. If there is nothing to read before poll-timeout-seconds, return [].

This does not remove the messages from the queue! For that, see ack.

Does not catch Exceptions that might be thrown while attempting to receive messages from the queue.

enqueue clj

(enqueue queue-connection message & {:as opts})

Enqueues a message to a queue.

Input: queue-connection - A connection to a queue made with mk-connection message - The message to be placed on the queue

Optional arguments: :message-attributes - A map of SQS Attributes to apply to this message. :serialization-fn - A function that serializes the message you want to enqueue to a string :message-group-id - This parameter applies to FIFO queues only :message-deduplication-id - This parameter applies to FIFO queues only

By default, pr-str will be used

invalid-queue-message clj

maximum-retries clj

Maximum number of retries before sending a message to the dead letter queue.

mk-connection clj

(mk-connection queue-name & {:keys [client] :as options})

Make an SQS connection to a queue identified by string queue-name. This should be done once at startup time.

Will throw QueueDoesNotExistException if the queue does not exist. configure-queue can be used to create and configure the queue.

nack clj

(nack connection message)

(nack {:keys [client queue-url]}
      {:keys [receipt-handle]}
      nack-visibility-seconds)

Put the message back on the queue.

Input: connection - as created by mk-connection message - the message to nack nack-visibility-seconds (optional) - How long to wait before retrying a failed compute request. Defaults to 0.

parse-queue-name clj

(parse-queue-name queue-name)

poll-timeout-seconds clj

How long to wait for a response when polling for new messages on the queue.

valid-queue-name? clj

(valid-queue-name? queue-name)

Returns true if an SQS queue name is valid, false otherwise

validate-queue-name! clj

(validate-queue-name! queue-name)

Validates input for SQS queue names.

Returns nil, or throws an IllegalArgumentException on invalid queue name.