input {

  file {
    type => "logs"
    path => "/app-logs/**/*.log"
    codec => json
  }

}

filter {
  mutate {
    add_field => { "app_id" => "ks8"}
  }
}


output {
   rabbitmq {
      host => "log.int-onemall.com"
      exchange => ks8
      key => ks8
      exchange_type => fanout
      durable => false
      user => "wondermall"
      password => "sabizore"
   }

}