Example: Stdin to NSQ

NSQ

The experimental plugin set allows input/output from NSQ Servers. The parameters are available in the docs

STDIN to NSQ

input {
  stdin {}
}

output {
  nsq {
    dataUrl => '10.0.0.1'
    topic => 'new_topic'
  }
}

NSQ to STDOUT

input {
  nsq {
    host => '10.0.0.1'
    port => 4161
    chanel => 'some_channel'
    topic => 'new_topic'
  }
}

output {
  stdout {}
}

NSQ to AMQP

input {
  nsq {
    host => '10.0.0.1'
    port => 4161
    chanel => 'some_channel'
    topic => 'nsq_topic'
  }
}

output{
  amqp {
    host => '10.0.0.2'
    port => 5672
    exchange_name => pastash
    topic => 'amqp_topic'
  }
}