From 42bbdd78c92a1e5651d343f35159fd80dc91ca08 Mon Sep 17 00:00:00 2001 From: Mike Place Date: Fri, 26 Apr 2019 17:38:03 +0200 Subject: [PATCH] Use pluginmetadata Fixes #10561 --- logstash-core/lib/logstash/java_pipeline.rb | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/logstash-core/lib/logstash/java_pipeline.rb b/logstash-core/lib/logstash/java_pipeline.rb index faa1dd77c..1360dd5e0 100644 --- a/logstash-core/lib/logstash/java_pipeline.rb +++ b/logstash-core/lib/logstash/java_pipeline.rb @@ -260,16 +260,11 @@ module LogStash; class JavaPipeline < JavaBasePipeline end def resolve_cluster_uuids - cluster_uuids = [] - outputs.each do |output| - if LogStash::SETTINGS.registered?(output.id + ".cluster_uuid") - cluster_uuid = LogStash::SETTINGS.get(output.id + ".cluster_uuid") - unless cluster_uuids.include? cluster_uuid - cluster_uuids.push(cluster_uuid) - end + outputs.each_with_object(Set.new) do |output, cluster_uuids| + if LogStash::PluginMetadata.exists?(output.id) + cluster_uuids << LogStash::PluginMetadata.for_plugin(output.id).get(:cluster_uuid) end - end - cluster_uuids + end.to_a.compact end def wait_inputs