sqs-consumer.core — signal-ai/sqs-consumer 0.2.1

create-consumer clj

(create-consumer {:keys [queue-url queue-name max-number-of-messages
                         wait-time-seconds shutdown-wait-time-ms process-fn
                         aws-config visibility-timeout run-dequeue-fn
                         thread-pool]
                  :or {shutdown-wait-time-ms 2000
                       wait-time-seconds 10
                       visibility-timeout 60
                       run-dequeue-fn default-top-level-error-handler
                       aws-config {:client-config {}}}})

run-dequeue-fn functions that wraps message dequeuing. Defaults to sleeping 1 second on exceptions.

dequeue clj

(dequeue {:keys [queue-url wait-time-seconds max-number-of-messages aws-config
                 visibility-timeout]
          :as config}
         f)

get-queue-url clj

(get-queue-url aws-config name)