Merge pull request #767 from logstash/LOGSTASH-1475

- Reconnect if redis appears down/dead (LOGSTASH-1475)
This commit is contained in:
Jordan Sissel 2013-11-08 10:36:16 -08:00
commit 9b1c732659

View file

@ -223,6 +223,10 @@ EOF
begin begin
@redis ||= connect @redis ||= connect
self.send listener, @redis, output_queue self.send listener, @redis, output_queue
rescue Redis::CannotConnectError => e
@logger.warn("Redis connection problem", :exception => e)
sleep 1
@redis = connect
rescue => e # redis error rescue => e # redis error
@logger.warn("Failed to get event from redis", :name => @name, @logger.warn("Failed to get event from redis", :name => @name,
:exception => e, :backtrace => e.backtrace) :exception => e, :backtrace => e.backtrace)