Jesque-based job queue
Allows enqueuing a simple Clojure function as a job. Job functions receive a map of injections as their first argument, passed in at worker startup, followed by any arguments that were provided when the job was enqueued.
Jesque-based job queue Allows enqueuing a simple Clojure function as a job. Job functions receive a map of injections as their first argument, passed in at worker startup, followed by any arguments that were provided when the job was enqueued.
Bound to the job info map (:name, :args) during execution (and middleware execution), mainly so Middleware can inspect what they are wrapping.
Bound to the job info map (:name, :args) during execution (and middleware execution), mainly so Middleware can inspect what they are wrapping.
(connect)(connect {:keys [host port middleware] :or {host "127.0.0.1" port 6379}})Create a Jesque client with a Redis connection pool
Create a Jesque client with a Redis connection pool
(end-client {:keys [client]})Stop the client, close connections
Stop the client, close connections
(enqueue {:keys [client]} queue var-name & args)Enqueue a new job
Enqueue a new job
(job var-name args)Create a new job, the first argument is the fully qualified name of a Clojure var
Create a new job, the first argument is the fully qualified name of a Clojure var
(run-worker! config queues injections)Create a new worker and run it on a new thread. Returns [worker thread]
Create a new worker and run it on a new thread. Returns [worker thread]
(unregister-worker client worker-name)Unregister worker from Redis
Unregister worker from Redis
(worker config queues injections)Create a new Jedis worker instance
Create a new Jedis worker instance
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |