class Resque::Failure::RedisMultiQueue
A Failure backend that stores exceptions in Redis. Very simple but works out of the box, along with support in the Resque web app.
Public Class Methods
all(offset = 0, limit = 1, queue = :failed, order = 'desc')
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 36 def self.all(offset = 0, limit = 1, queue = :failed, order = 'desc') Resque.list_range(queue, offset, limit, order) end
clear(queue = :failed)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 57 def self.clear(queue = :failed) Resque.redis.del(queue) end
count(queue = nil, class_name = nil)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 20 def self.count(queue = nil, class_name = nil) if queue if class_name n = 0 each(0, count(queue), queue, class_name) { n += 1 } n else Resque.redis.llen(queue).to_i end else total = 0 queues.each { |q| total += count(q) } total end end
each(offset = 0, limit = self.count, queue = :failed, class_name = nil, order = 'desc') { |offset| ... }
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 44 def self.each(offset = 0, limit = self.count, queue = :failed, class_name = nil, order = 'desc') items = all(offset, limit, queue, order) items = [items] unless items.is_a? Array if order.eql? 'desc' items.reverse! end items.each_with_index do |item, i| if !class_name || (item['payload'] && item['payload']['class'] == class_name) yield offset + i, item end end end
queues()
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 40 def self.queues Array(Resque.redis.smembers(:failed_queues)) end
remove(id, queue = :failed)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 68 def self.remove(id, queue = :failed) sentinel = "" Resque.redis.lset(queue, id, sentinel) Resque.redis.lrem(queue, 1, sentinel) end
remove_queue(queue)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 79 def self.remove_queue(queue) Resque.redis.del(Resque::Failure.failure_queue_name(queue)) end
requeue(id, queue = :failed)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 61 def self.requeue(id, queue = :failed) item = all(id, 1, queue) item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S") Resque.redis.lset(queue, id, Resque.encode(item)) Job.create(item['queue'], item['payload']['class'], *item['payload']['args']) end
requeue_queue(queue)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 74 def self.requeue_queue(queue) failure_queue = Resque::Failure.failure_queue_name(queue) each(0, count(failure_queue), failure_queue) { |id, _| requeue(id, failure_queue) } end
Public Instance Methods
filter_backtrace(backtrace)
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 83 def filter_backtrace(backtrace) index = backtrace.index { |item| item.include?('/lib/resque/job.rb') } backtrace.first(index.to_i) end
save()
click to toggle source
# File lib/resque/failure/redis_multi_queue.rb, line 6 def save data = { :failed_at => Time.now.strftime("%Y/%m/%d %H:%M:%S %Z"), :payload => payload, :exception => exception.class.to_s, :error => UTF8Util.clean(exception.to_s), :backtrace => filter_backtrace(Array(exception.backtrace)), :worker => worker.to_s, :queue => queue } data = Resque.encode(data) Resque.redis.rpush(Resque::Failure.failure_queue_name(queue), data) end