Auto log processor errors

Fix 352

lib/shoryuken/manager.rb

@@ -47,6 +47,11 @@ def stop(options = {})
       end
     end
 
+    def processor_failed(ex)
+      logger.error ex
+      logger.error ex.backtrace.join("\n") unless ex.backtrace.nil?
+    end
+
     def processor_done(queue)
       logger.debug { "Process done for '#{queue}'" }
     end

lib/shoryuken/processor.rb

@@ -13,6 +13,9 @@ def process(queue, sqs_msg)
       worker.class.server_middleware.invoke(worker, queue, sqs_msg, body) do
         worker.perform(sqs_msg, body)
       end
+    rescue Exception => ex
+      @manager.processor_failed(ex)
+      raise
     ensure
       @manager.processor_done(queue)
     end

spec/shoryuken/processor_spec.rb

@@ -99,6 +99,7 @@ def self.parse(*args)
       end
 
       it 'logs the error' do
+        expect(manager).to receive(:processor_failed)
         expect(subject.logger).to receive(:error) do |&block|
           expect(block.call).
             to include("unexpected token at 'invalid json'\nbody_parser: json\nsqs_msg.body: invalid json")
@@ -108,6 +109,7 @@ def self.parse(*args)
       end
 
       it 're raises the error' do
+        expect(manager).to receive(:processor_failed)
         expect { subject.process(queue, sqs_msg) }.
           to raise_error(JSON::ParserError, /unexpected token at 'invalid json'/)
       end