Contents

module Quebert
  module Consumer
    # The most Consumer. Doesn't even accept the queue as an argument because there's nothing
    # a job can do to be rescheduled, etc.
    class Base
      attr_reader :job
      
      def initialize(job)
        @job = job
      end
      
      def perform
        begin
          job.perform(*job.args)
        rescue Job::Action
          # Nothing to do chief!
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
quebert-0.0.4	lib/quebert/consumer/base.rb
quebert-0.0.3	lib/quebert/consumer/base.rb
quebert-0.0.1	lib/quebert/consumer/base.rb
quebert-0.0.0	lib/quebert/consumer/base.rb