Liking cljdoc? Tell your friends :D

oc.lib.sqs

A component to consume messages from an SQS queue with a long poll and pass them off to a handler, deleting them if they are processed successfully (no exception) by the handler.

https://github.com/stuartsierra/component

A component to consume messages from an SQS queue with a long poll and pass them off to a handler, deleting them if
they are processed successfully (no exception) by the handler.

https://github.com/stuartsierra/component
raw docstring

__no-op__clj

(__no-op__)

Ignore: needed for Eastwood linting.

Ignore: needed for Eastwood linting.
sourceraw docstring

ackclj

(ack done-channel message)

Acknowledge the completion of message handling.

Acknowledge the completion of message handling.
sourceraw docstring

check-empty-queueclj

(check-empty-queue sqs-queue)
source

INTENTIONALLY-EMPTY-QUEUEclj

source

log-handlerclj

(log-handler handler message done-channel)

Message handler wrapper that logs unhandled errors.

Message handler wrapper that logs unhandled errors.
sourceraw docstring

read-message-bodyclj

(read-message-body msg)

Try to parse as json, otherwise use read-string. If message is from S3, read data object.

Try to parse as json, otherwise use read-string. If message is from S3, read data object.
sourceraw docstring

sqs-listenerclj

(sqs-listener {:keys [sqs-creds sqs-queue message-handler]})
(sqs-listener sqs-creds sqs-queue message-handler)
source

SQSListenerclj

source

warn-empty-queueclj

(warn-empty-queue sqs-queue)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close