# RabbitMQ output configuration - alternate-exchange - help needed **URL:** \ **Category:** Logstash\ **Created:** [July 28, 2016, 9:58am UTC](https://discuss.elastic.co/t/rabbitmq-output-configuration-alternate-exchange-help-needed/56601 "2016-07-28T09:58:45Z")\ **Posts on this page:** 4\ **Page:** 1
**Author:** ![vandamo](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/vandamo/32/8203_2.png) [@vandamo](https://discuss.elastic.co/u/vandamo)\ **Post date:** [July 28, 2016, 9:58am UTC](https://discuss.elastic.co/t/rabbitmq-output-configuration-alternate-exchange-help-needed/56601/1 "2016-07-28T09:58:45Z")
Hi, I'm trying out RabbitMQ (instead of Redis), and am typically creating the exchanges, bindings, queues in advance, then configuring logstash to match the existing config. There is one configuration I just tried now which is the option for an exchange to have an alternate-exchange configured. I do not know how to express that configuration in the logstash output plugin, and without it he generates an error: ``` :message=>"Pipeline aborted due to error", :exception=># ``` My latest config attempt (still fails, previous ones didn't include any reference to the alternate-exchange): ``` rabbitmq { exchange => "logstash" exchange_type => "direct" arguments => {"alternate-exchange" => "logstash-ae"} host => "localhost" port => 5672 key => "logstash" } ``` **Logstash Version: 2.3.4** any help would be greatly appreciated. ---
**Author:** ![magnusbaeck](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/magnusbaeck/32/44943_2.png) [@magnusbaeck](https://discuss.elastic.co/u/magnusbaeck)\ **Post date:** [July 31, 2016, 8:25pm UTC](https://discuss.elastic.co/t/rabbitmq-output-configuration-alternate-exchange-help-needed/56601/2 "2016-07-31T20:25:11Z")
If you're pre-creating exchanges and everything, shouldn't you do a passive bind? And in that case, wouldn't specifying the alternate exchange be pointless? ---
**Author:** ![vandamo](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/vandamo/32/8203_2.png) [@vandamo](https://discuss.elastic.co/u/vandamo)\ **Post date:** [August 1, 2016, 6:21am UTC](https://discuss.elastic.co/t/rabbitmq-output-configuration-alternate-exchange-help-needed/56601/3 "2016-08-01T06:21:39Z")
Hi Magnus, Thanks for your reply. From what I can see in the plugin documentation and the related github projects: - rabbitmq input: there is indeed a passive option, but focused on the queue creation the exchange creation _can_ be avoided by **not** providing exchange type - rabbitmq output: the documentation refers to a passive option, but there is no code implementation in relation to it, nor any information what it would cover, there is no way I see to bypass the exchange creation/validation I do agree that an option to do an all passive bind would be the most suitable approach for my use case, avoiding redundant configuration. I tried to "make it work" and have identified 3 modifications that are needed/missing: **logstash-mixin-rabbitmq\_connection** [rabbitmq\_connection.rb] ``` def declare_exchange!(channel, exchange, exchange_type, durable, arguments) @logger.debug? && @logger.debug("Declaring an exchange", :name => exchange, :type => exchange_type, :durable => durable) exchange = channel.exchange(exchange, :type => exchange_type.to_sym, :durable => durable, :arguments => arguments) @logger.debug? && @logger.debug("Exchange declared") exchange rescue StandardError => e @logger.error("Could not declare exchange!", :exchange => exchange, :type => exchange_type, :durable => durable, :arguments => arguments, :error_class => e.class.name, :error_message => e.message, :backtrace => e.backtrace) raise e end ``` Method should include an additional parameter **arguments** **logstash-output-rabbitmq** [rabbitmq.rb] ``` # Additional arguments for the exchange, for example could be the presence of an alternate exchange, ... config :arguments, :validate => :array, :default => {} ``` Additional parameter should be declared: **arguments** ... ``` def register connect! @hare_info.exchange = declare_exchange!(@hare_info.channel, @exchange, @exchange_type, @durable, @arguments) @codec.on_event(&method(:publish)) end ``` Method declare\_exchange should be called with _@arguments_ as additional parameter To be thorough, it would be better to also make following alteration: **logstash-input-rabbitmq** [rabbitmq.rb] ``` config :exchange_arguments, :validate => :array, :default => {} ``` Additional parameter should be declared: **exchange\_arguments** ... ``` def bind_exchange! if @exchange if @exchange_type # Only declare the exchange if @exchange_type is set! @logger.info? && @logger.info("Declaring exchange '#{@exchange}' with type #{@exchange_type}") @hare_info.exchange = declare_exchange!(@hare_info.channel, @exchange, @exchange_type, @durable, @exchange_arguments) end @hare_info.queue.bind(@exchange, :routing_key => @key) end end ``` Method declare\_exchange should be called with _@exchange\_arguments_ as additional parameter I have confirmed above changes are sufficient to allow for my situation to be resolved, but haven't run unit tests nor know too well (for now) the process for submitting such changes. Still, an option for binding in a completely passive manner would be the best approach from my point of view at least. ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 4:45am UTC](https://discuss.elastic.co/t/rabbitmq-output-configuration-alternate-exchange-help-needed/56601/4 "2017-07-06T04:45:37Z")