Resque.inline configuration support

In order perform Resque jobs inline introduced
Resque.inline attribute.

Author: bogdan

README.markdown

@@ -662,6 +662,11 @@ this way we can tell our Sinatra app about the config file:
 
 Now everyone is on the same page.
 
+Also, you could disable jobs queueing by setting 'inline' attribute.
+For example, if you want to run all jobs in the same process for cucumber, try:
+
+    Resque.inline = ENV['RAILS_ENV'] == "cucumber"
+
 
 Plugins and Hooks
 -----------------

lib/resque.rb

@@ -118,6 +118,17 @@ def to_s
     "Resque Client connected to #{redis_id}"
   end
 
+  # If 'inline' is true Resque will call #perform method inline
+  # without queuing it into Redis and without any Resque callbacks.
+  # The 'inline' is false Resque jobs will be put in queue regularly.
+  def inline?
+    @inline
+  end
+  alias_method :inline, :inline?
+
+  def inline=(inline)
+    @inline = inline
+  end
 
   #
   # queue manipulation
@@ -255,8 +266,8 @@ def reserve(queue)
 
   # Validates if the given klass could be a valid Resque job
   #
-  # If no queue can be inferred this method will raise a `Resque::NoQueueError` 
-  # 
+  # If no queue can be inferred this method will raise a `Resque::NoQueueError`
+  #
   # If given klass is nil this method will raise a `Resque::NoClassError`
   def validate!(klass)
     Job.validate!(klass)

lib/resque/job.rb

@@ -42,10 +42,16 @@ def initialize(queue, payload)
     def self.create(queue, klass, *args)
       validate!(klass, queue)
 
-      ret = Resque.push(queue, :class => klass.to_s, :args => args)
+      if Resque.inline?
+        ret = constantize(klass).perform(*decode(encode(args)))
+      else
+        ret = Resque.push(queue, :class => klass.to_s, :args => args)
+      end
+
       Plugin.after_enqueue_hooks(klass).each do |hook|
         klass.send(hook, *args)
       end
+
       ret
     end
 

test/resque_test.rb

@@ -8,7 +8,7 @@
     Resque.push(:people, { 'name' => 'bob' })
     Resque.push(:people, { 'name' => 'mark' })
   end
-  
+
   test "can set a namespace through a url-like string" do
     assert Resque.redis
     assert_equal :resque, Resque.redis.namespace
@@ -237,4 +237,14 @@
       Resque.decode("{\"error\":\"Module not found \\u002\"}")
     end
   end
+
+  test "inlining jobs" do
+    begin
+      Resque.inline = true
+      Resque.enqueue(SomeIvarJob, 20, '/tmp')
+      assert_equal 0, Resque.size(:ivar)
+    ensure
+      Resque.inline = false
+    end
+  end
 end