amqp input & output

indexer

input {                                                   
  amqp {                                                  
    # ship logs to the 'rawlogs' fanout queue.            
    type => "all"                                         
    debug => true                                         
    host => "33.33.33.10"                                 
    # Old syntax                                          
    # exchange_type => "fanout"                           
    # New syntax                                          
    exchange => "rawlogs_exchange"                        
    name => "rawlogs_queue"                               
    #exclusive => false                                   
    password => "bar"                                     
    user => "logstash"                                    
  }                                                       
}                                                         

shipper

output {                                                                
  # Output events to stdout for debugging. Feel free to remove          
  # this output if you don't need it.                                   
  stdout { }                                                            
                                                                        
  # Ship events to the amqp fanout queue named 'rawlogs"                
  amqp {                                                                
    debug => true                                                       
    durable => true                                                     
    persistent => false                                                 
    host => "33.33.33.10"                                               
    exchange_type => "direct"                                           
    name => "rawlogs_exchange"                                          
    user => "logstash"                                                  
    password => "bar"                                                   
  }                                                                     
}