proletarian.worker — msolli/proletarian 1.0.21-alpha

create-queue-worker clj

(create-queue-worker data-source)

(create-queue-worker data-source
                     {:proletarian/keys
                        [queue job-table archived-job-table serializer
                         context-fn log queue-worker-id polling-interval-ms
                         worker-threads await-termination-timeout-ms
                         install-jvm-shutdown-hook? on-shutdown clock]
                      :or {clock (Clock/systemUTC)
                           on-shutdown (fn* [] ())
                           log log/println-logger
                           await-termination-timeout-ms 10000
                           polling-interval-ms 100
                           archived-job-table db/DEFAULT_ARCHIVED_JOB_TABLE
                           install-jvm-shutdown-hook? false
                           queue db/DEFAULT_QUEUE
                           context-fn (constantly {})
                           serializer (transit/create-serializer)
                           worker-threads 1
                           job-table db/DEFAULT_JOB_TABLE}})

start! clj

(start! queue-worker)

stop! clj

(stop! queue-worker)