@filter_func = lambda do |event, &block|
    events = [event]
    @logger.debug? && @logger.debug("filter received", :event => event.to_hash)
            events = events.flat_map do |event|
              events = [event]
              if ((event["[type]"] == ("test".force_encoding(Encoding::UTF_8)))) # if [type] == "test"
                events = events.flat_map do |event|
                  next [] if event.cancelled?

                  new_events = []
                  @filter_noop_2.filter(event){|new_event| new_events << new_event}
                  event.cancelled? ? new_events : new_events.unshift(event)
                end


              end
              events
            end

    events.flatten.each{|e| block.call(e) }
  end
  @output_func = lambda do |event, &block|
    @logger.debug? && @logger.debug("output received", :event => event.to_hash)
            events = events.flat_map do |event|
              events = [event]
              if ((event["[type]"] == ("_grokparsefailure".force_encoding(Encoding::UTF_8)))) # if [type] == "_grokparsefailure"
      @output_stdout_3.handle(event)


              end
              events
            end

  end