Added Delay::Worker.delay_jobs configuration to allow delayed job to …

…operate in a test mode. When delay_jobs=false, all jobs are executed realtime; delay_jobs=true gives normal behavior with database backend.

README.textile

@@ -206,6 +206,8 @@ Delayed::Worker.destroy_failed_jobs = false. The failed jobs will be marked with
 
 By default all jobs are scheduled with priority = 0, which is top priority. You can change this by setting Delayed::Worker.default_priority to something else. Lower numbers have higher priority.
 
+It is possible to disable delayed jobs for testing purposes. Set Delayed::Worker.delay_jobs = false to execute all jobs realtime.
+
 Here is an example of changing job parameters in Rails:
 
 <pre>
@@ -214,6 +216,7 @@ Delayed::Worker.destroy_failed_jobs = false
 Delayed::Worker.sleep_delay = 60
 Delayed::Worker.max_attempts = 3
 Delayed::Worker.max_run_time = 5.minutes
+Delayed::Worker.delay_jobs = !Rails.env.test?
 </pre>
 
 h3. Cleaning up

lib/delayed/message_sending.rb

@@ -10,7 +10,12 @@ def initialize(payload_class, target, options)
     end
 
     def method_missing(method, *args)
-      Job.enqueue({:payload_object => @payload_class.new(@target, method.to_sym, args)}.merge(@options))
+      payload_object = @payload_class.new(@target, method.to_sym, args)
+      if Delayed::Worker.delay_jobs
+        Job.enqueue({:payload_object => payload_object}.merge(@options))
+      else
+        payload_object.perform
+      end
     end
   end
 

lib/delayed/worker.rb

@@ -6,11 +6,12 @@
 
 module Delayed
   class Worker
-    cattr_accessor :min_priority, :max_priority, :max_attempts, :max_run_time, :default_priority, :sleep_delay, :logger
+    cattr_accessor :min_priority, :max_priority, :max_attempts, :max_run_time, :default_priority, :sleep_delay, :logger, :delay_jobs
     self.sleep_delay = 5
     self.max_attempts = 25
     self.max_run_time = 4.hours
     self.default_priority = 0
+    self.delay_jobs = true
 
     # By default failed jobs are destroyed after too many attempts. If you want to keep them around
     # (perhaps to inspect the reason for the failure), set this to false.

spec/message_sending_spec.rb

@@ -85,5 +85,32 @@ def spin
       job.run_at.should == run_at
       job.priority.should == 20
     end
+
+    class FairyTail
+      attr_accessor :happy_ending
+      def tell
+        @happy_ending = true
+      end
+    end
+
+    it "should not delay the job when delay_jobs is false" do
+      Delayed::Worker.delay_jobs = false
+      fairy_tail = FairyTail.new
+      lambda {
+        lambda {
+          fairy_tail.delay.tell
+        }.should change(fairy_tail, :happy_ending).from(nil).to(true)
+      }.should_not change { Delayed::Job.count }
+    end
+
+    it "should delay the job when delay_jobs is true" do
+      Delayed::Worker.delay_jobs = true
+      fairy_tail = FairyTail.new
+      lambda {
+        lambda {
+          fairy_tail.delay.tell
+        }.should_not change(fairy_tail, :happy_ending)
+      }.should change { Delayed::Job.count }.by(1)
+    end
   end
 end