A simple Clojure PostgreSQL-based job queue. An optional web UI is also available as both a library and a standalone service.
See the API documentation for more detailed usage information, including examples.
(defn *-and-log [a b]
(println "a * b =" (* a b))
(Thread/sleep 20000))
(require 'cljobq.core)
(cljobq.core/set-context!
{:db
{:connection-uri "jdbc:postgresql://localhost:5432/jobq?user=jobq&password=jobq"}})
(cljobq.core/db-migrate!)
(cljobq.core/start
{:queues
{:queue-a {}
:queue-b {:num-threads 4}}})
(cljobq.core/enqueue
{:actor #'*-and-log
:args [9 9]
:queue "queue-b"})
(cljobq.core/enqueue
{:actor #'*-and-log
:args [9 7]
:job-name "recurring-math"
:queue "queue-c"
:interval "15 23 * * *"})
Copyright © 2018 Alex Hornung
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.
Can you improve this documentation?Edit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close