Method: Resque::Failure::RedisMultiQueue.requeue
- Defined in:
- lib/resque/failure/redis_multi_queue.rb
.requeue(id, queue = :failed) ⇒ Object
74 75 76 77 78 79 |
# File 'lib/resque/failure/redis_multi_queue.rb', line 74 def self.requeue(id, queue = :failed) item = all(id, 1, queue) item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S") data_store.update_item_in_failed_queue(id,Resque.encode(item),queue) Job.create(item['queue'], item['payload']['class'], *item['payload']['args']) end |