sqs-consumer.sequential — com.signal-ai/sqs-consumer 0.3.1

create-consumer clj

(create-consumer & {:keys [process-fn] :as args})

extract-message clj

(extract-message config message)

Extracts the message from the SQS receive messages response.

Each message is an SQS Message https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/index.html?com/amazonaws/services/sqs/model/Message.html.

sequential-process clj

(sequential-process process-fn)

with-auto-delete clj

(with-auto-delete process-fn)

Auto deletes the message from SQS whenever process-fn returns a truthy value. If a non-truthy value is returned or an exception is thrown the message will not be deleted.

with-error-handling clj

(with-error-handling process-fn error-handler)

Calls the given error handler when any error occurs further down the handler stack.