lib/pheme/queue_poller.rb in pheme-0.0.6 vs lib/pheme/queue_poller.rb in pheme-0.0.7

@@ -28,9 +28,11 @@
         queue_poller.poll(poller_configuration) do |message|
           data = parse_message(message)
           begin
             handle(data)
             queue_poller.delete_message(message)
+          rescue SignalException => e
+            throw :stop_polling
           rescue => e
             Pheme.log(:error, "Exception: #{e.inspect}")
             Pheme.log(:error, e.backtrace.join("\n"))
             Pheme.rollbar(e, "#{self.class} failed to process message", data)
           end