logstash/logstash — pull request #90 by knuckolls (2012-01-24 04:23:21+00:00)
Title: added amqp attributes config for rabbitmq mirrored queues

RabbitMQ mirrored queues use the x-ha-policy argument upon queue creation and client connection. In order to pull from a mirrored queue I had to expose the arguments hash from the bunny gem to the logstash config.

This is an example of how it's used. It uses the array format in lieu of a config parser for hashes.

The arguments array is in the format [ "key1", "value1", "key2", "value2", ... ]

input {
amqp {
# ship logs to the 'rawlogs' fanout queue.
type => "all"
host => "myhost"
exchange => "rawlogs"
name => "rawlogs"
durable => true exclusive => false
auto_delete => false
arguments => [ "x-ha-policy", "all" ]
}
}