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

error-is-safe-to-continue? clj

(error-is-safe-to-continue? error)

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
              initial-receiving-chan
              create-receiving-chan-fn
              out-chan)

(receive-loop sqs-ext-client
              queue-url
              initial-receiving-chan
              create-receiving-chan-fn
              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?)