LS Indexer

input {
    rabbitmq {
        #arguments => { "x-ha-policy" => "all" }
        host => "10.1.6.245"
        queue => "logstash-queue"
        key => "logstash-key"
        exchange => "logstash"
        threads => 400
        exclusive => false
        prefetch_count => 512
        vhost => "ELK"
        port => 5677
        user => "logstash"
        password => "****"
    }

}

output {
  elasticsearch {
    hosts => ["10.1.6.242:9200", "10.1.6.243:9200", "10.1.6.241:9200"]
    manage_template => false
    workers => 12
    index => "%{beatname}-%{+xxxx.ww}"
    document_type => "%{beattype}"
  }
}