clj-sqs-extended.internal.receive — motiva/clj-sqs-extended 0.2.4

assoc-done-fn-to-message clj

(assoc-done-fn-to-message sqs-ext-client queue-url message)

async-delete-message! clj

(async-delete-message! sqs-ext-client queue-url {receipt-handle :receiptHandle})

delete-message on the AWS SDK can block for many seconds. This fn runs sqs/delete-message! in the background.

Reference: https://www.selikoff.net/2018/02/14/the-amazon-aws-java-sqs-client-not-thread-safe/

delete-message-if-auto-delete clj

(delete-message-if-auto-delete auto-delete? {done-fn :done-fn :as message})

exit-receive-loop! clj

(exit-receive-loop! queue-url loop-stats receiving-chan)

handle-unexpected-message clj

(handle-unexpected-message queue-url
                           loop-stats
                           out-chan
                           receive-loop-running?
                           pause-and-restart-for-error?
                           receive-opts
                           message)

pause-to-recover-this-loop clj

(pause-to-recover-this-loop queue-url
                            pause-and-restart-for-error?
                            restart-delay-seconds
                            error)

put-legit-message-to-out-chan clj

(put-legit-message-to-out-chan {queue-url :queue-url out-chan :out-chan}
                               message)

receive-loop clj

(receive-loop sqs-ext-client queue-url out-chan)

(receive-loop sqs-ext-client
              queue-url
              out-chan
              {:keys [auto-delete restart-delay-seconds restart-limit]
               :as receive-opts}
              {:keys [max-number-of-receiving-messages]
               :or {max-number-of-receiving-messages 1}
               :as sqs-opts})

stop-receive-loop! clj

(stop-receive-loop! queue-url out-chan receive-loop-running?)