Contents

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

Version data entries

25 entries across 25 versions & 1 rubygems

Version	Path
quebert-3.3.0	lib/quebert/backend/in_process.rb
quebert-3.2.1	lib/quebert/backend/in_process.rb
quebert-3.2.0	lib/quebert/backend/in_process.rb
quebert-3.0.3	lib/quebert/backend/in_process.rb
quebert-3.0.2	lib/quebert/backend/in_process.rb
quebert-3.0.1	lib/quebert/backend/in_process.rb
quebert-3.0.0	lib/quebert/backend/in_process.rb
quebert-2.0.4	lib/quebert/backend/in_process.rb
quebert-2.0.3	lib/quebert/backend/in_process.rb
quebert-2.0.2	lib/quebert/backend/in_process.rb
quebert-2.0.1	lib/quebert/backend/in_process.rb
quebert-2.0.0	lib/quebert/backend/in_process.rb
quebert-1.12.0	lib/quebert/backend/in_process.rb
quebert-1.11.0	lib/quebert/backend/in_process.rb
quebert-1.0.9	lib/quebert/backend/in_process.rb
quebert-1.0.8	lib/quebert/backend/in_process.rb
quebert-1.0.7	lib/quebert/backend/in_process.rb
quebert-1.0.6	lib/quebert/backend/in_process.rb
quebert-1.0.5	lib/quebert/backend/in_process.rb
quebert-1.0.4	lib/quebert/backend/in_process.rb