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

async-delete-message! clj

(async-delete-message! sqs-ext-client queue-url message)

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/

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-and-maybe-delete-message clj

(put-legit-message-to-out-chan-and-maybe-delete-message
  {sqs-ext-client :sqs-ext-client
   queue-url :queue-url
   out-chan :out-chan
   auto-delete? :auto-delete?}
  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})

stop-receive-loop! clj

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