lambdaroyal.dispatch.core — org.clojars.gixxi/lambdaroyal-dispatch 0.8

dispatcher clj

(dispatcher & params)

Creates a dispatcher. Optional params are: :on-done :: job -> nil :on-failed :: {:keys [started-at stopped-at :error-message :id] :as job} -> nil :on-start :: job -> nil :frequency (default 1000) using this frequency we poll for jobs to execute :verbose (default false)

PDispatcher clj protocol

dispatch clj

(dispatch this queue es lambda)

dispatches a job for execution. queue is the name of the queues to dispatch the job to, es is the execution time (ET) as unix epoch, lambda λ is a parameterless function that gets called when the job to be executed

pause clj

(pause this queue)

pauses the execution of jobs for the queue with name queue

resume clj

(resume this queue)

resumes executing jobs in a given queue with name queue

stop clj

(stop this)

stop the dispatch from accepting new jobs, all currently running queue workers will eventually terminate. returns a promise (TODO: that gets realized once all jobs queue workers finished

uid clj

(uid)

returns a random key of length 9 containing [1..9 a..z A..Z] except for 0,I,O,l

when-let* clj macro

(when-let* bindings & body)