Liking cljdoc? Tell your friends :D
Clojure only.
kehaar.jobs
async->jobclj
(async->job chan)Like wire-up/async->fire-and-forget-fn, returns a function that sends the appropriate message on the channel so it gets routed to the appropriate service. Except it also takes a function to call every time an event comes through. Returns the job's routing-key.
Like wire-up/async->fire-and-forget-fn, returns a function that sends the appropriate message on the channel so it gets routed to the appropriate service. Except it also takes a function to call every time an event comes through. Returns the job's routing-key.
async->subjobclj
(async->subjob chan)Like async->job, but it's a 2-arity function that takes the routing-key as an arg.
Like async->job, but it's a 2-arity function that takes the routing-key as an arg.
async=>rabbitclj
(async=>rabbit chan rabbit-ch exchange routing-key)A jobs-specific async=>rabbit for job handlers that publishes a ::complete message once the channel is closed.
A jobs-specific async=>rabbit for job handlers that publishes a ::complete message once the channel is closed.
cancel!clj
(cancel! routing-key)Cancel a job by its routing key.
Cancel a job by its routing key.
complete!clj
(complete! routing-key)Record a completed worker.
Record a completed worker.
jobsclj
kehaar-exchangeclj
new-routing-keyclj
(new-routing-key)workers-chanclj
workers-chan-initialized?clj
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close