co.gaiwan.cljesque — co.gaiwan/cljesque 0.3.7

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.

connect clj

(connect)

(connect {:keys [host port] :or {host "127.0.0.1" port 6379}})

Create a Jesque client with a Redis connection pool

end-client clj

(end-client {:keys [client]})

Stop the client, close connections

enqueue clj

(enqueue {:keys [client]} queue var-name & args)

Enqueue a new job

injecting-job-factory clj

(injecting-job-factory injection-map)

Jedis Job factory. The job's "className" is treated as the fully qualified name of a clojure var/function. That functions will get called with the map of injections first, followed by the job arguments.

jedis-pool clj

(jedis-pool config)

job clj

(job var-name args)

Create a new job, the first argument is the fully qualified name of a Clojure var

make-config clj

(make-config redis-host redis-port)

queue-info-dao clj

(queue-info-dao {:keys [config pool]})

queue-infos clj

(queue-infos opts)

run-worker! clj

(run-worker! config queues injections)

Create a new worker and run it on a new thread. Returns [worker thread]

worker clj

(worker config queues injections)

Create a new Jedis worker instance