github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

Use pluginmetadata

Browse source 
Fixes #10561
This commit is contained in:
Mike Place 2019-04-26 17:38:03 +02:00 • committed by Shaunak Kashyap
parent dbea95111a
commit 42bbdd78c9
1 changed files with 4 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

13
logstash-core/lib/logstash/java_pipeline.rb
View file

@ -260,16 +260,11 @@ module LogStash; class JavaPipeline < JavaBasePipeline
end end
def resolve_cluster_uuids def resolve_cluster_uuids
cluster_uuids = [] outputs.each_with_object(Set.new) do |output, cluster_uuids|
outputs.each do |output| if LogStash::PluginMetadata.exists?(output.id)
if LogStash::SETTINGS.registered?(output.id + ".cluster_uuid") cluster_uuids << LogStash::PluginMetadata.for_plugin(output.id).get(:cluster_uuid)
cluster_uuid = LogStash::SETTINGS.get(output.id + ".cluster_uuid")
unless cluster_uuids.include? cluster_uuid
cluster_uuids.push(cluster_uuid)
end end
end end.to_a.compact
end
cluster_uuids
end end
def wait_inputs def wait_inputs