Sha256: 9c96f89d4083df476bec20de698c2535fe1853f041bf3b4625b83a74c2682def

Contents?: true

Size: 831 Bytes

Versions: 5

Compression:

Stored size: 831 Bytes

Contents

module Resque
  module Failure
    # A Failure backend that stores exceptions in Redis. 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.to_s,
          :payload   => payload,
          :error     => exception.to_s,
          :backtrace => exception.backtrace,
          :worker    => worker.to_s,
          :queue     => queue
        }
        data = Resque.encode(data)
        Resque.redis.rpush(:failed, data)
      end

      def self.count
        Resque.redis.llen(:failed).to_i
      end

      def self.all(start = 0, count = 1)
        Resque.list_range(:failed, start, count)
      end
      
      def self.clear
        Resque.redis.delete('resque:failed')
      end
      
    end
  end
end

Version data entries

5 entries across 5 versions & 2 rubygems

Version Path
resque-1.2.3 lib/resque/failure/redis.rb
resque-1.2.1 lib/resque/failure/redis.rb
resque-1.2.0 lib/resque/failure/redis.rb
jerefrer-resque-1.1.0 lib/resque/failure/redis.rb
resque-1.1.0 lib/resque/failure/redis.rb