Merge pull request #41 from joelio/master

Fix for LOGSTASH-130
2025-04-24 06:37:19 -04:00 · 2011-08-14 23:44:04 -07:00 · 2011-08-14 23:44:04 -07:00 · 480e78ba0a
commit 480e78ba0a
parent 2b06b8da95 f5b7ba731c
1 changed files with 3 additions and 0 deletions
--- a/lib/logstash/inputs/syslog.rb
+++ b/lib/logstash/inputs/syslog.rb
@ -120,6 +120,7 @@ class LogStash::Inputs::Syslog < LogStash::Inputs::Base
          source = "syslog://#{ip}/"
        end

+        begin
        client.each do |line|
          e = to_event(line.chomp, source)
          if e
@ -127,6 +128,8 @@ class LogStash::Inputs::Syslog < LogStash::Inputs::Base
            output_queue << e
          end # e
        end # client.each
+        rescue Errno::ECONNRESET
+        end
      end # Thread.new
    end # loop do
  ensure