class LogStash::Inputs::Tcp::TCPInput
Public Class Methods
new(url, receiver, logger)
click to toggle source
# File lib/logstash/inputs/tcp.rb, line 42 def initialize(url, receiver, logger) @logger = logger @receiver = receiver @url = url; @buffer = BufferedTokenizer.new # From eventmachine end
Public Instance Methods
receive_data(data)
click to toggle source
# File lib/logstash/inputs/tcp.rb, line 49 def receive_data(data) @buffer.extract(data).each do |line| port, host = Socket.unpack_sockaddr_in(self.get_peername) @receiver.receive(host, port, line) end end