From 937ed0ed2a1db1f4a6a8ca301b775cbc9908c7af Mon Sep 17 00:00:00 2001 From: Olivier Van Dam Date: Fri, 5 Aug 2016 12:25:07 +0200 Subject: [PATCH] Add support for arguments when declaring an exchange --- lib/logstash/outputs/rabbitmq.rb | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/lib/logstash/outputs/rabbitmq.rb b/lib/logstash/outputs/rabbitmq.rb index d394678..635697b 100644 --- a/lib/logstash/outputs/rabbitmq.rb +++ b/lib/logstash/outputs/rabbitmq.rb @@ -36,9 +36,12 @@ class RabbitMQ < LogStash::Outputs::Base # Should RabbitMQ persist messages to disk? config :persistent, :validate => :boolean, :default => true + # Additional arguments for the exchange, for example could be the presence of an alternate exchange, ... + config :arguments, :validate => :array, :default => {} + def register connect! - @hare_info.exchange = declare_exchange!(@hare_info.channel, @exchange, @exchange_type, @durable) + @hare_info.exchange = declare_exchange!(@hare_info.channel, @exchange, @exchange_type, @durable, @arguments) @codec.on_event(&method(:publish)) end