# File lib/fluent/plugin_helper/event_emitter.rb, line 52 def initialize super @_event_emitter_used_actually = false @router = nil end
# File lib/fluent/plugin_helper/event_emitter.rb, line 64 def after_shutdown @router = nil super end
# File lib/fluent/plugin_helper/event_emitter.rb, line 69 def close # unset router many times to reduce test cost @router = nil super end
# File lib/fluent/plugin_helper/event_emitter.rb, line 58 def configure(conf) require 'fluent/engine' super @router = event_emitter_router(conf['@label']) end
# File lib/fluent/plugin_helper/event_emitter.rb, line 44 def event_emitter_router(label_name) if label_name Engine.root_agent.find_label(label_name).event_router else Engine.root_agent.event_router end end
# File lib/fluent/plugin_helper/event_emitter.rb, line 40 def event_emitter_used_actually? @_event_emitter_used_actually end
# File lib/fluent/plugin_helper/event_emitter.rb, line 36 def has_router? true end
stop : [-] shutdown : disable @router close : [-] terminate: [-]
# File lib/fluent/plugin_helper/event_emitter.rb, line 27 def router @_event_emitter_used_actually = true @router end
# File lib/fluent/plugin_helper/event_emitter.rb, line 32 def router=(r) @router = r end
# File lib/fluent/plugin_helper/event_emitter.rb, line 74 def terminate @router = nil super end