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.
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
__no-op__clj
(__no-op__)Ignore: needed for Eastwood linting.
Ignore: needed for Eastwood linting.
ackclj
(ack done-channel message)Acknowledge the completion of message handling.
Acknowledge the completion of message handling.
log-handlerclj
(log-handler handler message done-channel)Message handler wrapper that logs unhandled errors.
Message handler wrapper that logs unhandled errors.
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.
sqs-listenerclj
(sqs-listener {:keys [sqs-creds sqs-queue message-handler]})(sqs-listener sqs-creds sqs-queue message-handler)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close