Method: Resque::Failure::Redis.remove_queue

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

.remove_queue(queue) ⇒ Object 



86
87
88
89
90
91
92
93
94
95
96
 
# File 'lib/resque/failure/redis.rb', line 86

def self.remove_queue(queue)
  i = 0
  while job = all(i)
    if job['queue'] == queue
      # This will remove the failure from the array so do not increment the index.
      remove(i)
    else
      i += 1
    end
  end
end