lib/logstash/filters/aggregate.rb
def init_pipeline_timeout_management()
    
    # Define default flush instance that manages timeout (if not defined by user)
    if !@current_pipeline.flush_instance_map.has_key?(@task_id)
      @current_pipeline.flush_instance_map[@task_id] = self
    end

    # Define timeout and inactivity_timeout (if not defined by user)
    if @current_pipeline.flush_instance_map[@task_id] == self
      if @timeout.nil?
        @timeout = DEFAULT_TIMEOUT
        @logger.debug("Aggregate timeout for '#{@task_id}' pattern: #{@timeout} seconds (default value)")
      end
      if @inactivity_timeout.nil?
        @inactivity_timeout = @timeout
      end
    end

  end
# init flush/timeout properties for current pipeline
init flush/timeout properties for current pipeline
init flush / timeout properties for current pipeline
def init_pipeline_timeout_management()
    if !@current_pipeline.flush_instance_map.has_key?(@task_id)
      @current_pipeline.flush_instance_map[@task_id] = self
    end
    if @current_pipeline.flush_instance_map[@task_id] == self
      if @timeout.nil?
        @timeout = DEFAULT_TIMEOUT
        @logger.debug("Aggregate timeout for '#{@task_id}' pattern: #{@timeout} seconds (default value)")
      end
      if @inactivity_timeout.nil?
        @inactivity_timeout = @timeout
      end
    end
  end
def init_pipeline_timeout_management ( ) if ! @current_pipeline . flush_instance_map . has_key? ( @task_id ) @current_pipeline . flush_instance_map [ @task_id ] = self end if @current_pipeline . flush_instance_map [ @task_id ] == self if @timeout . nil? @timeout = DEFAULT_TIMEOUT @logger . debug ( "Aggregate timeout for '#{@task_id}' pattern: #{@timeout} seconds (default value)" ) end if @inactivity_timeout . nil? @inactivity_timeout = @timeout end end end
init flush/timeout properties for current pipeline
init flush / timeout properties for current pipeline
# Define default flush instance that manages timeout (if not defined by user) # Define timeout and inactivity_timeout (if not defined by user)