lib/ears/middlewares/max_retries.rb in ears-0.11.2 vs lib/ears/middlewares/max_retries.rb in ears-0.12.0
- old
+ new
@@ -13,9 +13,10 @@
@error_queue = opts.fetch(:error_queue)
end
def call(delivery_info, metadata, payload, app)
return handle_exceeded(payload) if retries_exceeded?(metadata)
+
app.call(delivery_info, metadata, payload)
end
private