module QueueingRabbit::JobExtensions::Retryable

Public Instance Methods

retries() click to toggle source
# File lib/queueing_rabbit/extensions/retryable.rb, line 7
def retries
  headers['qr_retries'].to_i
end
retry_upto(max_retries) click to toggle source
# File lib/queueing_rabbit/extensions/retryable.rb, line 11
def retry_upto(max_retries)
  if retries < max_retries
    updated_headers = headers.update('qr_retries' => retries + 1)
    self.class.enqueue(payload, :headers => updated_headers)
  end
end