Example: File to AMQP

ZMQ

PaStash natively support AMQP exchange such as RabbitMQ (required) for distribution and queuing of data and 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 {}
}