logstash-core/lib/logstash/java_pipeline.rb
# After `shutdown` is called from an external thread this is called from the main thread to
# tell the worker threads to stop and then block until they've fully stopped
# This also stops all filter and output plugins
After `shutdown` is called from an external thread this is called from the main thread to
tell the worker threads to stop and then block until they've fully stopped
This also stops all filter and output plugins
After ` shutdown ` is called from an external thread this is called from the main thread to tell the worker threads to stop and then block until they ' ve fully stopped This also stops all filter and output plugins
def shutdown_workers
    @shutdownRequested.set(true)
    @worker_threads.each do |t|
      @logger.debug("Shutdown waiting for worker thread" , default_logging_keys(:thread => t.inspect))
      t.join
    end
    @filters.each(&:do_close)
    @outputs.each(&:do_close)
  end
def shutdown_workers @shutdownRequested . set ( true ) @worker_threads . each do | t | @logger . debug ( "Shutdown waiting for worker thread" , default_logging_keys ( :thread => t . inspect ) ) t . join end @filters . each ( & :do_close ) @outputs . each ( & :do_close ) end
After `shutdown` is called from an external thread this is called from the main thread to
tell the worker threads to stop and then block until they've fully stopped
This also stops all filter and output plugins
After ` shutdown ` is called from an external thread this is called from the main thread to tell the worker threads to stop and then block until they ' ve fully stopped This also stops all filter and output plugins