lib/pheme/queue_poller.rb in pheme-4.0.3 vs lib/pheme/queue_poller.rb in pheme-4.0.5

@@ -56,23 +56,21 @@
     def poll
       time_start = log_polling_start
       queue_poller.poll(poller_configuration) do |queue_message|
         @messages_received += 1
         Pheme.logger.tagged(queue_message.message_id) do
-          begin
-            content = parse_body(queue_message)
-            metadata = parse_metadata(queue_message)
-            message_attributes = parse_message_attributes(queue_message)
-            with_optional_connection_pool_block { handle(content, metadata, message_attributes) }
-            queue_poller.delete_message(queue_message)
-            log_delete(queue_message)
-            @messages_processed += 1
-          rescue SignalException
-            throw :stop_polling
-          rescue StandardError => e
-            Pheme.logger.error(e)
-            Pheme.rollbar(e, "#{self.class} failed to process message", { message: content })
-          end
+          content = parse_body(queue_message)
+          metadata = parse_metadata(queue_message)
+          message_attributes = parse_message_attributes(queue_message)
+          with_optional_connection_pool_block { handle(content, metadata, message_attributes) }
+          queue_poller.delete_message(queue_message)
+          log_delete(queue_message)
+          @messages_processed += 1
+        rescue SignalException
+          throw :stop_polling
+        rescue StandardError => e
+          Pheme.logger.error(e)
+          Pheme.rollbar(e, "#{self.class} failed to process message", { message: content })
         end
       end
       log_polling_end(time_start)
     end
     # rubocop:enable Metrics/AbcSize