lib/messaging/routes.rb in messaging-3.8.1 vs lib/messaging/routes.rb in messaging-3.8.2
- old
+ new
@@ -14,10 +14,10 @@
def define_consumers!
return unless consumers.empty?
consumer_definitions.each do |name, definition|
- c = Messaging.consumer_adapter.create_consumer(name, definition.fetch(:options))
+ c = Messaging.consumer_adapter.create_consumer(name, **definition.fetch(:options))
definition.fetch(:block)&.call(c)
consumers << c
end
end