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