Contents

module Qe
  def self.jobs
    @jobs ||= []
  end

  def self.drain
    jobs.each do |job|
      Qe::Worker.perform(job[:worker].name, job[:options])
    end
  end

  class Testing
    def self.enqueue(worker, options = {})
      Qe.jobs << {worker: worker, options: options}
    end

    def self.schedule(worker, run_at, options = {})
      Qe.jobs << {worker: worker, options: options, run_at: run_at}
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
qe-0.4.0	lib/qe/testing.rb
qe-0.3.5	lib/qe/testing.rb
qe-0.3.4	lib/qe/testing.rb
qe-0.3.3	lib/qe/testing.rb
qe-0.3.2	lib/qe/testing.rb