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