Module: Resque::Plugins::Retried

Included in:
RetryOnFail, RetryOnLock
Defined in:
lib/resque/plugins/retried.rb

Instance Method Summary collapse

Instance Method Details

#args_for_try_again(*args) ⇒ Object

Modify the arguments used to requeue the job. Use this to do something other than try the exact same job again.



24
25
26
 
# File 'lib/resque/plugins/retried.rb', line 24

def args_for_try_again(*args)
  args
end

#seconds_until_retry ⇒ Object

Override in your subclass to control how long to wait before performing this job again. Retrying comes in two flavors:

  1. ‘ResqueScheduler` If Resque responds to `enqueue_in`, the job will be scheduled to perform again in the defined number of seconds.

  2. ‘sleep` If Resque does not respond to `enqueue_in`, then we simply sleep for the defined number of seconds before enqueing the job. This method is NOT recommended because it will block your worker.

Return nil to perform no delay.



18
19
20
 
# File 'lib/resque/plugins/retried.rb', line 18

def seconds_until_retry
  Resque.respond_to?(:enqueue_in) ? 5 : 1
end

#try_again(*args) ⇒ Object 



28
29
30
31
32
33
34
35
 
# File 'lib/resque/plugins/retried.rb', line 28

def try_again(*args)
  if Resque.respond_to?(:enqueue_in)
    Resque.enqueue_in(seconds_until_retry || 0, self, *args_for_try_again(*args))
  else
    sleep(seconds_until_retry) if seconds_until_retry
    Resque.enqueue(self, *args_for_try_again(*args))
  end
end