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

Flush until it succeeds

Browse source
This commit is contained in:
Jordan Sissel 2012-09-02 18:14:29 -07:00
parent ddecf89a28
commit a5bfa5526b
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/logstash/outputs/elasticsearch_http.rb
View file

@ -101,7 +101,9 @@ class LogStash::Outputs::ElasticSearchHTTP < LogStash::Outputs::Base
event.to_json
].join("\n")
flush if @queue.size >= @flush_size
# Keep trying to flush while the queue is full.
# This will cause retries in flushing if the flush fails.
flush while @queue.size >= @flush_size
end # def receive_bulk
def flush