class Fluent::ForwardOutput

def emit(tag, es, chain)
  data = es.to_msgpack_stream
  if @buffer.emit(tag, data, chain)  # use key = tag
    submit_flush
  end
end