Contents

module Resque
  module Failure
    # All Failure classes are expected to subclass Base.
    #
    # When a job fails, a new instance of your Failure backend is created
    # and #save is called.
    class Base
      # The exception object raised by the failed job
      attr_accessor :exception

      # The worker object who detected the failure
      attr_accessor :worker

      # The string name of the queue from which the failed job was pulled
      attr_accessor :queue

      # The payload object associated with the failed job
      attr_accessor :payload

      def initialize(exception, worker, queue, payload)
        @exception = exception
        @worker    = worker
        @queue     = queue
        @payload   = payload
      end

      # When a job fails, a new instance of your Failure backend is created
      # and #save is called.
      #
      # This is where you POST or PUT or whatever to your Failure service.
      def save
      end

      # The number of failures.
      def self.count
        0
      end

      # The number of failures after a search.
      def self.search_count
        0
      end

      # Returns a paginated array of failure objects.
      def self.all(start = 0, count = 1)
        []
      end

      # Returns a paginated array of failure objects after a search.
      def self.search_results(query, start = 0, count = 1)
        []
      end

      # A URL where someone can go to view failures.
      def self.url
      end
      
      # Clear all failure objects
      def self.clear
      end
      
      def self.requeue(index)
      end

      def self.remove(index)
      end

      # Logging!
      def log(message)
        @worker.log(message)
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
nfo-resque-mongo-1.17.2	lib/resque/failure/base.rb
nfo-resque-mongo-1.17.1	lib/resque/failure/base.rb
nfo-resque-mongo-1.15.1	lib/resque/failure/base.rb
nfo-resque-mongo-1.15.0	lib/resque/failure/base.rb