proletarian.job
enqueue!clj
(enqueue! conn job-type payload)(enqueue! conn
job-type
payload
{:proletarian/keys [queue job-table serializer uuid-fn now-fn]
:or {queue db/DEFAULT_QUEUE
job-table db/DEFAULT_JOB_TABLE
serializer (transit/create-serializer)
uuid-fn (fn* [] (UUID/randomUUID))
now-fn (fn* [] (Instant/now))}})handle-job!cljmultimethod
This multimethod is called by the Proletarian poller when a job is ready for execution. Implement this multimethod for your job type. The return value from your handler is discarded. If it throws, it is retried according to its retry strategy (see retry-strategy).
If handle-job! is missing an implementation for a job type found in the job queue, it would result in an exception. Then the job would be retried according to its retry-strategy (which defaults to no retries).
This multimethod is called by the Proletarian poller when a job is ready for execution. Implement this multimethod for your job type. The return value from your handler is discarded. If it throws, it is retried according to its retry strategy (see retry-strategy). If handle-job! is missing an implementation for a job type found in the job queue, it would result in an exception. Then the job would be retried according to its retry-strategy (which defaults to no retries).
retry-strategycljmultimethod
When a job throws an exception, it is caught by the Proletarian poller. This function is then called with the job and the caught exception. This multimethod dispatches on the job type. You can implement this method for your job type to have it retry any way you want based on the information in the job record and the caught exception.
It should return a map that specifies the retry strategy: :retries The number of retries (note that the total number of attempts will be one larger than this number). :delays A vector of numbers of milliseconds to wait between retries.
Do consider the polling interval and the job queue contention when planning your retry strategy. The retry delay should be thought of as the earliest time that the job will be retried. The actual retry time might be a little, or much, later, depending on the polling interval and what other jobs are in the queue before this one.
Examples: {:retries 2 :delays [1000 5000]} => This will retry two times. The first time after 1 second and the second after 5 seconds.
{:retries 4 :delays [2000 10000]} => This will retry four times. The first time after 2 seconds, and the last three times after 10 seconds.
When a job throws an exception, it is caught by the Proletarian poller.
This function is then called with the job and the caught exception. This
multimethod dispatches on the job type. You can implement this method for
your job type to have it retry any way you want based on the information in
the job record and the caught exception.
It should return a map that specifies the retry strategy:
:retries The number of retries (note that the total number of attempts will
be one larger than this number).
:delays A vector of numbers of milliseconds to wait between retries.
Do consider the polling interval and the job queue contention when planning
your retry strategy. The retry delay should be thought of as the earliest
time that the job will be retried. The actual retry time might be a little,
or much, later, depending on the polling interval and what other jobs are in
the queue before this one.
Examples:
{:retries 2
:delays [1000 5000]}
=> This will retry two times. The first time after 1 second and the second
after 5 seconds.
{:retries 4
:delays [2000 10000]}
=> This will retry four times. The first time after 2 seconds, and the last
three times after 10 seconds.cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close