Class: Fluent::ReemitOutput::V14EventRouter

Inherits:

V12EventRouter

• Object
• V12EventRouter
• Fluent::ReemitOutput::V14EventRouter

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

• #emit_stream(tag, es) ⇒ Object

  copy from fluentd.

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

# File 'lib/fluent/plugin/out_reemit.rb', line 119

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