Method: Resque::Failure::Redis.requeue_queue
- Defined in:
- lib/resque/failure/redis.rb
.requeue_queue(queue) ⇒ Object
78 79 80 81 82 83 84 |
# File 'lib/resque/failure/redis.rb', line 78 def self.requeue_queue(queue) i = 0 while job = all(i) requeue(i) if job['queue'] == queue i += 1 end end |