#output
 rabbitmq {
    exchange => "logstash-rabbitmq"
    exchange_type => "direct"
    key => "logstash-key"
    host => "x.x.x.x"
    workers => 12
    durable => true
    persistent => true
  }


#input  rabbitmq {
        host => "x.x.x.x"
        add_field  => { "environment" => "production" }
        queue => "logstash-queue"
        durable => true
        key => "logstash-key"
        exchange => "logstash-rabbitmq"
        exclusive => false
        auto_delete => false
        threads => 3
        prefetch_count => 20
        port => 5672
        user => "guest"
        password => "guest"
    }