logstash-core/lib/logstash/pipeline_action/create.rb
# The execute assume that the thread safety access of the pipeline
# is managed by the caller.
The execute assume that the thread safety access of the pipeline
is managed by the caller.
The execute assume that the thread safety access of the pipeline is managed by the caller .
def execute(agent, pipelines)
      pipeline =
        if @pipeline_config.settings.get_value("pipeline.java_execution")
          LogStash::JavaPipeline.new(@pipeline_config, @metric, agent)
        else
          LogStash::Pipeline.new(@pipeline_config, @metric, agent)
        end
      status = pipeline.start 
      if status
        pipelines[pipeline_id] = pipeline 
      end
      LogStash::ConvergeResult::ActionResult.create(self, status)
    end
def execute ( agent , pipelines ) pipeline = if @pipeline_config . settings . get_value ( "pipeline.java_execution" ) LogStash :: JavaPipeline . new ( @pipeline_config , @metric , agent ) else LogStash :: Pipeline . new ( @pipeline_config , @metric , agent ) end status = pipeline . start if status pipelines [ pipeline_id ] = pipeline end LogStash :: ConvergeResult :: ActionResult . create ( self , status ) end
The execute assume that the thread safety access of the pipeline
is managed by the caller.
The execute assume that the thread safety access of the pipeline is managed by the caller .
# block until the pipeline is correctly started or crashed # The pipeline is successfully started we can add it to the hash
agent
<not_specific>
pipelines
<not_specific>