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

assoc-done-fn-to-message clj

(assoc-done-fn-to-message message-delete-fn
                          {receipt-handle :receiptHandle :as message})

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?
                           restart-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 out-chan message)

receive-loop clj

(receive-loop queue-url
              out-chan
              message-receiver-fn
              message-delete-fn
              {:keys [auto-delete? restart-opts]})

receive-to-channel clj

(receive-to-channel message-receiver-fn)

stop-receive-loop! clj

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