# File lib/fluent/plugin/in_udp.rb, line 32 def configure(conf) super @message_length_limit = @body_size_limit if @body_size_limit end
# File lib/fluent/plugin/in_udp.rb, line 38 def listen(callback) log.info "listening udp socket on #{@bind}:#{@port}" @usock = SocketUtil.create_udp_socket(@bind) @usock.bind(@bind, @port) SocketUtil::UdpHandler.new(@usock, log, @message_length_limit, callback, !!@source_hostname_key, @remove_newline) end