Added Qe.drain for testing execution.

lib/qe/testing.rb

@@ -3,6 +3,12 @@ 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}

spec/qe/testing_spec.rb

@@ -18,4 +18,18 @@
 
     expect(job).to include(run_at: date)
   end
+
+  it "runs jobs" do
+    Qe::Testing.enqueue(HelloWorker, a: 1)
+
+    instance = double.as_null_object
+    instance.should_receive(:perform)
+
+    HelloWorker
+      .should_receive(:new)
+      .with(a: 1)
+      .and_return(instance)
+
+    Qe.drain
+  end
 end