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