class Fluent::UdpInput

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_udp.rb, line 34
def configure(conf)
  super

  @message_length_limit = @body_size_limit if @body_size_limit
end
listen(callback) click to toggle source
# File lib/fluent/plugin/in_udp.rb, line 40
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, @receive_buffer_size)
end