Class: Fluent::ReemitOutput::V14EventRouter

Inherits:
V12EventRouter show all
Defined in:
lib/fluent/plugin/out_reemit/v14_event_router.rb

Overview

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

Instance Method Summary collapse

Methods inherited from V12EventRouter

#find, #initialize, #match

Constructor Details

This class inherits a constructor from Fluent::ReemitOutput::V12EventRouter

Instance Method Details

#emit_stream(tag, es) ⇒ Object

copy from fluentd



14
15
16
17
18
 
# 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 ⇒ Object 



9
10
11
 
# File 'lib/fluent/plugin/out_reemit/v14_event_router.rb', line 9

def filter_class
  ::Fluent::Plugin::Filter
end