com.moclojer.rq.queue — com.moclojer/rq 0.1.1

consumer clj

(consumer redis-client
          queue-name
          consumer-fn
          &
          {:keys [size loop-sleep direction]
           :or {direction "l" size -1 loop-sleep 0}})

Consume a message from the queue, blocking in loop until a message is available.

consumer-size clj

(consumer-size redis-client queue-name)

get size of the queue

pattern-name clj

(pattern-name name)

Return the pattern name for the queue, which is the name prefixed with rq:

producer clj

(producer redis-client
          queue-name
          message
          &
          {:keys [direction at in retry retry-delay]
           :or {direction "l" retry 3 retry-delay 10}})

Push a job to the queue