A clojure library for Redis-based message queues.
Featuring:
- Retries
- Failure backlog, with limits on depth
- Limits on queue depth
- JSON serialization
Put this in your project.cljc
[threatgrid/redismq "0.1.0-SNAPSHOT"];; define our test queue
(def queue (make-queue "test" {:host "localhost}))
;; put some events on the queue
(enqueue queue "Truly")
(enqueue queue "I")
(enqueue queue "am")
(enqueue queue "awesome")
;; we'll pull one off the queue
(consume queue (fn [event] (print "First Event: " event)))
;; a reaper will check the processing queue, and clean up dead events
;; we have it check every 10 seconds
(queue-reaper 10 queue)
;; This starts up a worker that will wait 1 second between events, and
;; will block attempting to read an even at most 10 seconds to process
;; the event.
(queue-worker queue
(fn [event]
(print "Event: " event))
:delay 1
:timeout 10))
;; and when you are done
(stop-workers @queue-workers)
(stop-reaper (first @queue-workers))
Copyright © 2016 Cisco
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.