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

fix missing method worker_threads_draining? in ruby pipeline (#15013)

Browse source 
This commit adds the missing method `worker_threads_draining?` to ruby pipeline which is added in #13934 to java pipeline for log msg improvement

Fixed: #15010
This commit is contained in:
kaisecheng 2023-04-20 11:20:00 +01:00 • committed by GitHub
parent 0e5d0a9eb9
commit 71d64a96a2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

7
logstash-core/lib/logstash/pipeline.rb
View file

@ -659,6 +659,13 @@ module LogStash; class Pipeline < BasePipeline
} }
end end
# This is for backward compatibility of ruby engine. ShutdownWatcherExt.start() requires this method
# In java pipeline, the return boolean indicates if PQ is draining
# By giving false, log msg works in the same way prior to queue drain log msg improvement #13934
def worker_threads_draining?
false
end
private private
def close_plugin_and_ignore(plugin) def close_plugin_and_ignore(plugin)