Method: Fluent::Plugin::Output#emit_events

Defined in:
lib/fluent/plugin/output.rb

#emit_events(tag, es) ⇒ Object



873
874
875
876
877
878
879
880
# File 'lib/fluent/plugin/output.rb', line 873

def emit_events(tag, es)
  # actually this method will be overwritten by #configure
  if @buffering
    emit_buffered(tag, es)
  else
    emit_sync(tag, es)
  end
end