lib/logstash/inputs/tcp.rb in logstash-input-tcp-2.0.4 vs lib/logstash/inputs/tcp.rb in logstash-input-tcp-2.0.5

- old
+ new

@@ -155,9 +155,13 @@ end rescue EOFError @logger.debug? && @logger.debug("Connection closed", :client => socket.peer) rescue Errno::ECONNRESET @logger.debug? && @logger.debug("Connection reset by peer", :client => socket.peer) + rescue OpenSSL::SSL::SSLError => e + # Fixes issue #23 + @logger.error("SSL Error", :exception => e, :backtrace => e.backtrace) + socket.close rescue nil rescue => e # if plugin is stopping, don't bother logging it as an error !stop? && @logger.error("An error occurred. Closing connection", :client => socket.peer, :exception => e, :backtrace => e.backtrace) ensure # catch all rescue nil on close to discard any close errors or invalid socket