Liking cljdoc? Tell your friends :D
cljdekiq.queue
Queuecljprotocol
A generic interface over the stateful queue semantics.
A generic interface over the stateful queue semantics.
closeclj
(close this)Clean up any of the queue components.
Clean up any of the queue components.
pollclj
(poll this queues)Poll for new work. Called repeatedly. Can return [] or nil to indicate no work available.
Poll for new work. Called repeatedly. Can return [] or nil to indicate no work available.
pushclj
(push this job)Insert a new job. Use the job map to infer all routing logic.
Insert a new job. Use the job map to infer all routing logic.
retryclj
(retry this job retry-at)Retry a job
Retry a job
scheduleclj
(schedule this job enqueue-at)Similar to push but for scheduling a job in the future.
Similar to push but for scheduling a job in the future.
tickclj
(tick this)Called every N seconds to allow the queue to advance internal machinery. Returns the next ticket delay in seconds.
Called every N seconds to allow the queue to advance internal machinery. Returns the next ticket delay in seconds.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close