resque failures

resque-retry.rb

describe "job failures" do
  it 'retries with limited attempts' do
    require 'resque/failure/redis'
    Resque.unstub(:enqueue)

    Resque::Failure::MultipleWithRetrySuppression.classes = [Resque::Failure::Redis]
    Resque::Failure.backend = Resque::Failure::MultipleWithRetrySuppression

    JobWithError = Class.new do
      @queue = "test"
      extend Resque::Plugins::Retry

      def self.perform
        raise ArgumentError
      end
    end

    Resque.enqueue(JobWithError)
    worker = Resque::Worker.new("test")

    process_job(worker)
    Resque::Failure.count.should be_zero

    process_job(worker)
    Resque::Failure.count.should == 1

    should_have_no_jobs(worker)
  end

  def should_have_no_jobs(worker)
    worker.reserve.should be_nil
  end

  def process_job(worker)
    job = worker.reserve
    worker.perform(job)
  end
end