class Fluent::ReemitOutput::V14EventRouter

Almost same as V12EventRouter but (1) it must call emit_events instead of emit (2) Filter class is Fluent::Plugin::Filter instead of Fluent::Filter

Public Instance Methods

emit_stream(tag, es) click to toggle source

copy from fluentd

# File lib/fluent/plugin/out_reemit/v14_event_router.rb, line 14
def emit_stream(tag, es)
  match(tag).emit_events(tag, es)
rescue => e
  @emit_error_handler.handle_emits_error(tag, es, e)
end
filter_class() click to toggle source
# File lib/fluent/plugin/out_reemit/v14_event_router.rb, line 9
def filter_class
  ::Fluent::Plugin::Filter
end