tech.queue

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.

Examples

Please see queue-test.

For using the worker abstraction, please see worker-test.

License

Copyright © 2018 TechAscent, LLC.

Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.