Liking cljdoc? Tell your friends :D

com.timezynk.domus.mongo.queue


createclj

(create & {:as params})

DEFAULT_MAX_ATTEMPTSclj


DEFAULT_MIN_INTERVALclj


DEFAULT_MIN_SLEEPclj


DEFAULT_NUM_WORKERSclj


DEFAULT_RETRY_INTERVAL_MSclj

Milliseconds to wait for before retrying a failed job.

Milliseconds to wait for before retrying a failed job.
raw docstring

DEFAULT_THREAD_PRIORITYclj

Priority to assign to worker threads, if none specified at creation.

Priority to assign to worker threads, if none specified at creation.
raw docstring

drainclj

(drain queue)

Puts the calling thread to sleep until the length of queue becomes zero.

Puts the calling thread to sleep until the length of `queue` becomes zero.
raw docstring

failed-queue-collection-nameclj

(failed-queue-collection-name queue)

Name of the collection which holds the failed jobs.

Name of the collection which holds the failed jobs.
raw docstring

MAX_RETRY_INTERVAL_MSclj


WorkQueuecljprotocol

lengthclj

(length this)

Number of currently enqueued jobs.

Number of currently enqueued jobs.

start-workers!clj

(start-workers! this thread-name)

Starts all worker threads.

Starts all worker threads.

stop-workers!clj

(stop-workers! this)

Stops all worker threads.

Stops all worker threads.

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
Move to previous article
Move to next article
Ctrl+/Jump to the search field
× close