This commit is contained in:
Jordan Sissel 2010-11-18 00:55:35 -08:00
parent 42b7333b04
commit b4a0dfeb4e

View file

@ -39,7 +39,7 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
@receiver = receiver
@url = url;
@buffer = BufferedTokenizer.new # From eventmachine
end
end # def initialize
def receive_data(data)
@buffer.extract(data).each do |line|