module SidekiqUniqueRetries::Extensions::JobRetry

Public Instance Methods

attempt_retry(worker, msg, queue, exception) click to toggle source
Calls superclass method
# File lib/sidekiq_unique_retries/extensions/job_retry.rb, line 6
def attempt_retry(worker, msg, queue, exception)
  if SidekiqUniqueRetries.lockable?(msg)
    if SidekiqUniqueRetries.lock(msg)
      super
    else
      logger.info { "Ignore retry for #{msg['class']} job #{msg['jid']}" }
    end
  else
    super
  end
end
retries_exhausted(worker, msg, exception) click to toggle source
Calls superclass method
# File lib/sidekiq_unique_retries/extensions/job_retry.rb, line 18
def retries_exhausted(worker, msg, exception)
  if SidekiqUniqueRetries.lockable?(msg)
    SidekiqUniqueRetries.unlock(msg)
  end

  super
end