Contents

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
quebert-0.0.6	lib/quebert/backend/in_process.rb