Contents

module Quebert
  module Backend
    # Drops jobs on an array in-process.
    class InProcess < Array
      def put(job, *args)
        unshift Job.to_json(job, *args)
      end
      
      def reserve
        json = pop and Consumer::Base.new(Job.from_json(json))
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
quebert-0.0.4	lib/quebert/backend/in_process.rb
quebert-0.0.3	lib/quebert/backend/in_process.rb
quebert-0.0.1	lib/quebert/backend/in_process.rb
quebert-0.0.0	lib/quebert/backend/in_process.rb