github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

LOGSTASH-88: fix typo which broke tcp inputs, and better exception logging

Browse source
This commit is contained in:
Pete Fritchman 2011-05-19 14:15:02 -07:00
parent f45daac12c
commit dc60484f0f
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/logstash/inputs/tcp.rb
View file

@ -50,11 +50,11 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
"@tags" => @tags.clone,
})
e.source = "tcp://#{@host}:#{@port}/client/#{peer}"
@logger.debug(["Received message from #{peer}"], e)
@logger.debug(["Received message from #{peer}", e])
output_queue << e
end # loop do
rescue
@logger.debug("Closing connection with #{peer}")
@logger.debug(["Closing connection with #{peer}", $!])
rescue Timeout::Error
@logger.debug("Closing connection with #{peer} after read timeout")
end # begin