Made sure that recover() gets passed the message in.

dbalatero · Jun 10, 2009 · 60c56aa · 60c56aa
1 parent e8bd107
commit 60c56aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/queue_stick/worker.rb b/lib/queue_stick/worker.rb
@@ -61,7 +61,7 @@ def run_loop
         error = WorkerError.new(message)
         error.exceptions << process_error
         begin
-          recover
+          recover(message.body)
         rescue Exception => recover_error
           error.exceptions << recover_error
         end