Module: QueueingRabbit::JobExtensions::Retryable

Defined in:
lib/queueing_rabbit/extensions/retryable.rb

Instance Method Summary collapse

Instance Method Details

#retries ⇒ Object 



7
8
9
 
# File 'lib/queueing_rabbit/extensions/retryable.rb', line 7

def retries
  headers['qr_retries'].to_i
end

#retry_upto(max_retries) ⇒ Object 



11
12
13
14
15
16
 
# 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