class Fluent::UdpInput
Public Instance Methods
listen(callback)
click to toggle source
# File lib/fluent/plugin/in_udp.rb, line 10 def listen(callback) log.debug "listening udp socket on #{@bind}:#{@port}" @usock = SocketUtil.create_udp_socket(@bind) @usock.bind(@bind, @port) SocketUtil::UdpHandler.new(@usock, log, @body_size_limit, callback) end