class JoobQ::ExponentialBackoff

Defined in:

joobq/middlewares/retry.cr

Class Method Summary

Class Method Detail

def self.cleanup_retry_lock(job : JoobQ::Job, queue : BaseQueue) : Nil #

Clean up retry lock when job completes successfully


[View source]
def self.move_to_dead_letter(job : JoobQ::Job, queue : BaseQueue) : JoobQ::Job #

Move job from processing to dead letter queue Returns the modified job with dead status


[View source]
def self.retry_idempotent(job : JoobQ::Job, queue : BaseQueue, retry_attempt : Int32) : Tuple(Bool, JoobQ::Job) #

Idempotent retry that prevents duplicate retries for the same job Returns a tuple of (success: Bool, modified_job: Job)


[View source]