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