Use correct execution engine for test-and-exit mode

Fixes #11067
This commit is contained in:
Dan Hermann 2019-08-14 10:46:06 -05:00
parent 0e90733c84
commit c75ef874ae

View file

@ -336,7 +336,8 @@ class LogStash::Runner < Clamp::StrictCommand
# TODO(ph): make it better for multiple pipeline # TODO(ph): make it better for multiple pipeline
if results.success? if results.success?
results.response.each do |pipeline_config| results.response.each do |pipeline_config|
LogStash::BasePipeline.new(pipeline_config) pipeline_class = pipeline_config.settings.get_value("pipeline.java_execution") ? LogStash::JavaPipeline : LogStash::BasePipeline
pipeline_class.new(pipeline_config)
end end
puts "Configuration OK" puts "Configuration OK"
logger.info "Using config.test_and_exit mode. Config Validation Result: OK. Exiting Logstash" logger.info "Using config.test_and_exit mode. Config Validation Result: OK. Exiting Logstash"