input { rabbitmq { key => "nessus" queue => "nessus" durable => true exchange => "nessus" user => "logstash" password => "yourpassword" host => "buffer01" port => 5672 tags => [ "queue_nessus", "rabbitmq" ] } }