Method: Resque::Failure::Redis.requeue

Defined in:
lib/resque/failure/redis.rb

.requeue(index) ⇒ Object



32
33
34
35
36
37
# File 'lib/resque/failure/redis.rb', line 32

def self.requeue(index)
  item = all(index)
  item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S")
  Resque.redis.lset(:failed, index, Resque.encode(item))
  Job.create(item['queue'], item['payload']['class'], *item['payload']['args'])
end