Theoretical plugin API for Qu

plugin.rb

module AutoRetry
  include Qu::Plugin

  configure do
    def autoretry(*errors)
      self.config = {:limit => 3}.merge!(errors.extract_options!)
      errors << Exception if errors.empty?
      config[:errors] = errors

      before :failure, :try_again
    end
  end

  def try_again(e)
    if errors.any? {|error| error === e }
      data[:retries] += 1
      if data[:retries] <= config[:limit]
        Qu.requeue self
        halt # don't report the error yet
      end
    end
  end
end

usage.rb

# Declare plugin for all Jobs
Qu::Job.plugin AutoRetry


class ProcessPresentation < Qu::Job
  autoretry Timeout::Error, :times => 5

  attr_reader :presentation

  def initialize(presentation_id)
    @presentation = Presentation.find(presentation)
  end

  def perform
    # …
  end
end