class Fluent::Plugin::NullOutput

def initialize
  super
  @delayed = false
  @feed_proc = nil
end

def multi_workers_ready?
  true
end

def prefer_buffered_processing
  false
end

def prefer_delayed_commit
  @delayed
end

def process(tag, es)
  raise "failed to flush" if @never_flush
  # Do nothing
end

def try_write(chunk)
  raise "failed to flush" if @never_flush
  if @feed_proc
    @feed_proc.call(chunk)
  end
  # not to commit chunks for testing
  # commit_write(chunk.unique_id)
end

def write(chunk)
  raise "failed to flush" if @never_flush
  if @feed_proc
    @feed_proc.call(chunk)
  end
end