fix: fix broken specs

marcosgz · Feb 11, 2025 · 19b151c · 19b151c
1 parent 3b4a8fa
commit 19b151c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/lepus/consumer.rb b/lib/lepus/consumer.rb
@@ -104,6 +104,8 @@ def process_delivery(delivery_info, metadata, payload)
           nest_middleware(middleware, next_middleware)
         end
         .call(message)
+    rescue Lepus::InvalidConsumerReturnError
+      raise
     rescue Exception => ex # rubocop:disable Lint/RescueException
       # @TODO: add error handling
       logger.error(ex)