diff --git a/logstash-core/lib/logstash/config/source/multi_local.rb b/logstash-core/lib/logstash/config/source/multi_local.rb index c2819d8a2dd..74ea8e97b63 100644 --- a/logstash-core/lib/logstash/config/source/multi_local.rb +++ b/logstash-core/lib/logstash/config/source/multi_local.rb @@ -4,6 +4,7 @@ module LogStash module Config module Source class MultiLocal < Local + include LogStash::Util::SubstitutionVariables include LogStash::Util::Loggable def initialize(settings) @@ -13,7 +14,7 @@ def initialize(settings) end def pipeline_configs - pipelines = retrieve_yaml_pipelines() + pipelines = deep_replace(retrieve_yaml_pipelines()) pipelines_settings = pipelines.map do |pipeline_settings| clone = @original_settings.clone clone.merge_pipeline_settings(pipeline_settings)