Example: File to AMQP

ZMQ

PaStash natively support AMQP exchange such as RabbitMQ for distribution and queuing of processed messages.

Log Agent(s)

input {
  file {
    path => "/var/log/nginx/access.log"
  }
}

amqp {
    host => log_server
    port => 5672
    exchange_name => pastash
  }

Log Server

input {
  amqp {
    host => localhost
    port => 5672
    exchange_name => pastash
  }
}

output {
  stdout {}
}