class Fluent::ForwardOutput::HeartbeatHandler

def initialize(io, callback)
  super(io)
  @io = io
  @callback = callback
end

def on_readable
  msg, addr = @io.recvfrom(1024)
  host = addr[3]
  port = addr[1]
  sockaddr = Socket.pack_sockaddr_in(port, host)
  @callback.call(sockaddr, msg)
rescue
  # TODO log?
end