github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-23 22:27:21 -04:00
Code Issues Projects Releases Packages Wiki Activity

Close redis connection on teardown

Browse source
This commit is contained in:
Bob Corsaro 2011-05-30 20:31:15 -04:00
parent 2aa21df735
commit ee223789ab
2 changed files with 11 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/logstash/inputs/redis.rb
View file

@ -126,6 +126,8 @@ class LogStash::Inputs::Redis < LogStash::Inputs::Base
def teardown
if @data_type == 'channel' and @redis
@redis.unsubscribe
@redis.quit
@redis = nil
end
end
end # class LogStash::Inputs::Redis

9
lib/logstash/outputs/redis.rb
View file

@ -69,4 +69,13 @@ class LogStash::Outputs::Redis < LogStash::Outputs::Base
raise e
end
end # def receive
public
def teardown
if @data_type == 'channel' and @redis
@redis.quit
@redis = nil
end
end
end