zeromq filter support examples

external-event-filter.rb

require 'rubygems'
require 'ffi-rzmq'
require "json"

context = ZMQ::Context.new
socket = context.socket(ZMQ::REP)
socket.bind("tcp://*:2121")
msg = ''
puts "starting up"
while true do
  socket.recv_string(msg)
  puts "Recieved message: #{msg}"
  modified_message = JSON.parse(msg)
  modified_message["@message"] = "changed externally"
  modified_message["@source_path"] = "fuck you"
  puts "Modified message: #{modified_message.to_json}"
  socket.send_string(modified_message.to_json)
end

external-event.conf

input { stdin { type => "stdin-test" } }
filter { zeromq {  } }
output { stdout { debug => true }}

external-field-filter.rb

require 'rubygems'
require 'ffi-rzmq'
require "json"

context = ZMQ::Context.new
socket = context.socket(ZMQ::REP)
socket.bind("tcp://*:2121")
msg = ''
puts "starting up"
while true do
  socket.recv_string(msg)
  puts "Recieved message: #{msg}"
  modified_message = "this field was changed externally"
  puts "Modified message: #{modified_message}"
  socket.send_string(modified_message)
end

external-field.conf

input { stdin { type => "stdin-test" } }
filter { zeromq { field => "@source_path" } }
output { stdout { debug => true }}