class Fluent::Plugin::RelabelOutput

def multi_workers_ready?
  true
end

def process(tag, es)
  router.emit_stream(tag, es)
end