class Riemann::Babbler::Plugin::ResponderUdp

Public Instance Methods

init() click to toggle source
# File lib/riemann/babbler/plugins/responder_udp.rb, line 5
def init
  host, port = opts.riemann.responder_bind_udp.split(':')
  plugin.set_default(:port, port)
  plugin.set_default(:host, host)
end
process(data, src) click to toggle source
# File lib/riemann/babbler/plugins/responder_udp.rb, line 11
def process(data, src)
  begin
    report event_from_json(data)
    src.reply "sended\n"
  rescue
    log :error, "Failed to send message: #{data.inspect}"
    src.reply "failed to send: #{data.inspect}\n"
  end    
end
run!() click to toggle source
# File lib/riemann/babbler/plugins/responder_udp.rb, line 21
def run!
  log :unknown, "Start udp server at #{plugin.host}:#{plugin.port}"
  Socket.udp_server_loop(plugin.host, plugin.port) do |data, src|
    log :debug, "Recived data: #{data.inspect}, from client: #{src.inspect}"
    process(data, src) 
  end
end