gistfile1.txt

input {                                                                                                     
  amqp {                                                                                                    
    # AMQP connection details                                                                               
    host => "<%= amqpHost %>"                                                                               
    user => "<%= amqpUser %>"                                                                               
    vhost => "<%= amqpVhost %>"                                                                             
    password => "<%= amqpPassword %>"                                                                       
    # This name has to be same across indexer to have each indexer take only 1 message from the queue       
    name => "indexer_queue"                                                                                 
    # Queue settings (needs to mirror all other consumer/producers)                                         
    exclusive => false                                                                                      
    durable => true                                                                                         
    auto_delete => false                                                                                    
    # Exchange to bind to                                                                                   
    exchange => "logs_exchange"                                                                          
    # This is needed for direct exchange                                                                    
    key => "logstash"                                                                                       
    type => "logstash-indexer-input"                                                                        
  }