full.aws.sqs — fullcontact/full.aws 1.0.0

change-message-visibility> clj

(change-message-visibility> {:keys [queue-url receipt-handle] :as message}
                            visibility-timeout)

client clj

create-queue> clj

(create-queue> queue-name attributes)

default-extend-visibility-after clj

default-visibility-timeout clj

delete-message> clj

(delete-message> {:keys [queue-url receipt-handle] :as message})

delete-queue> clj

(delete-queue> queue-name)

fetch-delay clj

get-queue-attributes> clj

(get-queue-attributes> queue-url)

list-queues> clj

(list-queues> prefix)

max-max-messages clj

max-visibility-timeout clj

max-wait-time clj

message-count-fetch-interval clj

monitor-queue-size clj

(monitor-queue-size queue-url)

Periodically pools queue size and submits to Riemann.

parse-int clj

(parse-int v)

parse-long-ts clj

(parse-long-ts v)

parse-ts clj

(parse-ts v)

receive-messages> clj

(receive-messages> queue-url)

(receive-messages> queue-url
                   {:keys [wait-time max-messages visibility-timeout
                           unserializer]
                    :or {wait-time max-wait-time
                         max-messages max-max-messages
                         visibility-timeout default-visibility-timeout
                         unserializer read-edn}})

receive-messages>> clj

(receive-messages>> queue-url)

(receive-messages>> queue-url
                    {:keys [wait-time max-messages visibility-timeout
                            unserializer]
                     :or {wait-time max-wait-time
                          max-messages max-max-messages
                          visibility-timeout default-visibility-timeout
                          unserializer read-edn}})

Continously receive messages from AWS with long-polling. Returns an inifinite channel that will yield the received messages.

send-message-batch clj

(send-message-batch queue-url bodies)

(send-message-batch queue-url
                    bodies
                    {:keys [serializer] :or {serializer write-edn}})

send-message-batch> clj

(send-message-batch> queue-url bodies)

(send-message-batch> queue-url bodies options)

send-message> clj

(send-message> message)

(send-message> {:keys [queue-url body] :as message}
               {:keys [delay-seconds serializer] :or {serializer write-edn}})

set-dead-letter-queue> clj

(set-dead-letter-queue> source-queue-url
                        dead-letter-queue-url
                        &
                        {:keys [max-receive-count] :or {max-receive-count 5}})

set-queue-attributes> clj

(set-queue-attributes> queue-url attributes)

sqs-endpoint clj

str-or-nil clj

(str-or-nil value)

subscribe clj

(subscribe queue-url handler>)

(subscribe queue-url
           handler>
           {:keys [visibility-timeout extend-visibility-after unserializer
                   parallelism retries auto-delete]
            :or {visibility-timeout default-visibility-timeout
                 extend-visibility-after default-extend-visibility-after
                 unserializer read-edn
                 parallelism 1
                 retries [5 60 900 3600]
                 auto-delete true}})

Repeatedly fetches messages from SQS queue and invokes handler function for each message with specified parallelism. Automatically retries messages with configurable delay. Parameters:

• queue-url SQS queue URL
• handle> handler function, should accept one parameter (message) and return channel that gets closed when message is processed. If channel yields exception, the message will be retried after a delay
• :parallelism Max number of messages to handle in parallel. Default 10.
• :retries Vector of retry intervals in seconds, for example [4 10] will mean that first time the message will be retry after 4 +-2 sec, second and following times after 10 +-5 sec.
• :visibility-timeout Number of seconds message is not visible to other consumers once received.
• :extend-visibility-after Number of seconds after which visibility timeout is automatically extended to allow additional processing time. Should be less than :visibility-timeout. Set to nil to disable.
• :auto-delete Whether to automatically delete successfully handled messages. Default is true