proletarian.protocols — msolli/proletarian 1.0.21-alpha

QueueWorker clj protocol

The process that runs the job workers for a particular queue.

start! clj

(start! _)

Sets up a thread pool and starts polling for jobs.

stop! clj

(stop! _)

Shuts down the job workers and the thread pool. Will allow running jobs to complete before shutting down the thread pool.

Serializer clj protocol

decode clj

(decode _ data-string)

encode clj

(encode _ data)