Contents

module Resque
  module Failure
    # A Failure backend that stores exceptions in Mongo. Very simple but
    # works out of the box, along with support in the Resque web app.
    class Redis < Base
      def save
        data = {
          :failed_at => Time.now.strftime("%Y/%m/%d %H:%M:%S"),
          :payload   => payload,
          :exception => exception.class.to_s,
          :error     => exception.to_s,
          :backtrace => Array(exception.backtrace),
          :worker    => worker.to_s,
          :queue     => queue
        }
        Resque.mongo_failures << data
      end

      def self.count
        Resque.mongo_failures.count
      end

      def self.all(start = 0, count = 1)
        all_failures = Resque.mongo_failures.find().sort([:natural, :desc]).skip(start).limit(count).to_a
       # all_failures.size == 1 ? all_failures.first : all_failures        
      end

      def self.clear
        Resque.mongo_failures.remove
      end

      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
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
resque-igo-1.12.8	lib/resque/failure/redis.rb
resque-igo-1.12.7	lib/resque/failure/redis.rb
resque-igo-1.12.6	lib/resque/failure/redis.rb
resque-igo-1.12.5	lib/resque/failure/redis.rb
resque-igo-1.12.4	lib/resque/failure/redis.rb
resque-igo-1.12.3	lib/resque/failure/redis.rb
resque-igo-1.12.2	lib/resque/failure/redis.rb
resque-igo-1.12.1	lib/resque/failure/redis.rb
resque-igo-1.1.5	lib/resque/failure/redis.rb
resque-igo-1.1.4	lib/resque/failure/redis.rb
resque-igo-1.1.3	lib/resque/failure/redis.rb
resque-igo-1.1.2	lib/resque/failure/redis.rb
resque-igo-1.1.1	lib/resque/failure/redis.rb
resque-igo-1.1	lib/resque/failure/redis.rb