FYI, https://ask.clojure.org is in maintenance mode right now as I sort through some updates, should be back on tomorrow. sorry for the inconvenience
all fixed up, ask away!
Hi all, Piped is a new library for processing messages from Amazon's Simple Queue Service (SQS). It makes use of aws-api and core.async to implement a message processing machine with easy-to-implement hooks for user space code. Feedback and issue reports are certainly welcome as it's quite young. Find it at https://github.com/RutledgePaulV/piped. Main Features: - lightweight (no amazonica!) - graceful shutdown sequence - automatic lease extensions - batches calls to aws for receiving and acking - decent performance (still need to benchmark others though) - supports blocking and non-blocking consumers
Looks like the core.async aspect is fully internal, I like it!
yep, no need to use core.async as a user! but optionally you can return a channel from a handler with a result of :ack or :nack.. I should document that part 🙂