Class: Fluent::ReemitOutput::V14EventRouter

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

Overview

Almost same as V12EventRouter but it must call #emit_events instead of #emit.

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

same



127
128
129
130
131
 
# File 'lib/fluent/plugin/out_reemit.rb', line 127

def emit_stream(tag, es)
  match(tag).emit_events(tag, es)
rescue => e
  @emit_error_handler.handle_emits_error(tag, es, e)
end