class LogStash::Inputs::Syslog::UDPInput

Public Class Methods

new(receiver, logger) click to toggle source
# File lib/logstash/inputs/syslog.rb, line 116
def initialize(receiver, logger)
  @logger = logger
  @receiver = receiver
end

Public Instance Methods

receive_data(data) click to toggle source

Every udp packet is a unique message.

# File lib/logstash/inputs/syslog.rb, line 122
def receive_data(data)
  port, host = Socket.unpack_sockaddr_in(self.get_peername)
  # Trim trailing newlines
  @receiver.receive(host, port, data.chomp)
end