lib/message_driver/middleware/middleware_stack.rb in message-driver-0.7.0 vs lib/message_driver/middleware/middleware_stack.rb in message-driver-0.7.1

- old
+ new

@@ -31,10 +31,10 @@ middleware.on_publish(*args) end end def on_consume(body, headers, properties) - @middlewares.reverse.reduce([body, headers, properties]) do |args, middleware| + @middlewares.reverse_each.reduce([body, headers, properties]) do |args, middleware| middleware.on_consume(*args) end end def empty?