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?