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

don't check for congestion on teardown

Browse source
This commit is contained in:
Piavlo 2013-03-28 13:49:54 +02:00
parent 0958a7315d
commit f41ea4f9f9
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -174,10 +174,11 @@ class LogStash::Outputs::Redis < LogStash::Outputs::Base
end
# called from Stud::Buffer#buffer_flush when there are events to flush
def flush(events, key)
def flush(events, key, teardown=false)
@redis ||= connect
# TODO(piavlo): we should not block due to congestion on teardown, to support this Stud::Buffer#buffer_flush should pass here the :final boolean arg.
congestion_check(key)
# TODO(piavlo): we should not block due to congestion on teardown
# to support this Stud::Buffer#buffer_flush should pass here the :final boolean value.
congestion_check(key) unless teardown
@redis.rpush(key, events)
end
# called from Stud::Buffer#buffer_flush when an error occurs