extracts worker.perform so call can be enhanced

- defines execute_job as an API hook

lib/sidekiq/processor.rb

@@ -49,7 +49,7 @@ def process(work)
 
         stats(worker, msg, queue) do
           Sidekiq.server_middleware.invoke(worker, msg, queue) do
-            worker.perform(*cloned(msg['args']))
+            execute_job(worker, cloned(msg['args']))
           end
         end
       rescue Sidekiq::Shutdown
@@ -71,6 +71,10 @@ def inspect
       "<Processor##{object_id.to_s(16)}>"
     end
 
+    def execute_job(worker, cloned_args)
+      worker.perform(*cloned_args)
+    end
+
     private
 
     def thread_identity

lib/sidekiq/testing.rb

@@ -153,7 +153,7 @@ def drain
         while job = jobs.shift do
           worker = new
           worker.jid = job['jid']
-          worker.perform(*job['args'])
+          execute_job(worker, job['args'])
         end
       end
 
@@ -163,7 +163,11 @@ def perform_one
         job = jobs.shift
         worker = new
         worker.jid = job['jid']
-        worker.perform(*job['args'])
+        execute_job(worker, job['args'])
+      end
+
+      def execute_job(worker, args)
+        worker.perform(*args)
       end
     end
 

test/test_processor.rb

@@ -39,6 +39,12 @@ def work(msg, queue='queue:default')
       assert_equal 1, $invokes
     end
 
+    it 'executes a worker as expected' do
+      worker = Minitest::Mock.new
+      worker.expect(:perform, nil, [1, 2, 3])
+      @processor.execute_job(worker, [1, 2, 3])
+    end
+
     it 'passes exceptions to ExceptionHandler' do
       actor = Minitest::Mock.new
       actor.expect(:real_thread, nil, [nil, Thread])

test/test_testing_fake.rb

@@ -261,5 +261,11 @@ def perform
       assert_equal 1, FirstWorker.count
       assert_equal 1, SecondWorker.count
     end
+
+    it 'can execute a job' do
+      worker = Minitest::Mock.new
+      worker.expect(:perform, nil, [1, 2, 3])
+      DirectWorker.execute_job(worker, [1, 2, 3])
+    end
   end
 end