class Fluent::ReemitOutput

Constants

EventRouter

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_reemit.rb, line 24
def configure(conf)
  super

  @router = EventRouter.new(self)
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/plugin/out_reemit.rb, line 34
def emit(tag, es, chain)
  @router.emit_stream(tag, es)
  chain.next
rescue => e
  log.warn "reemit: #{e.class} #{e.message} #{e.backtrace.first}"
end
included?(collector) click to toggle source
# File lib/fluent/plugin/out_reemit.rb, line 41
def included?(collector)
  return false if collector.nil?
  if collector == self
    true
  elsif collector.respond_to?(:outputs) # MultiOutput
    collector.outputs.each do |o|
      return true if self.included?(o)
    end
    false
  else
    false
  end
end
start() click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_reemit.rb, line 30
def start
  super
end