Example: File to AMQP

ZMQ

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

Log Agent(s)

Send messages with topic test on exchange pastash

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

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

Log Server

Receive messages from topic test on exchange pastash

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

output {
  stdout {}
}