Simple queue abstraction. Setup a queue/worker abstraction that will survive crashes and machine reboots.
Choose either filesystem or sqs to back your unordered queues.
(q/put! "file://tmp/queue-a" {:data 1})
(let [task (q/take! "file://temp/queue-a")]
(println (q/task->msg "file://temp/queue-a" task))
(q/complete! "file://temp/queue-a" task))Also implemented is a worker abstraction that works with the component library and enables robust, high volume processing of tasks in a system environment.
There are no ordering guarantees made across queue systems at this time.
Please see queue-test.
For using the worker abstraction, please see worker-test.
Copyright © 2018 TechAscent, LLC.
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.