output { if "nessus" in [tags]{ rabbitmq { key => "nessus" exchange => "nessus" exchange_type => "direct" user => "logstash" password => "yourbufferpassword" host => "buffer01" port => 5672 durable => true persistent => true } } }