Class: Karafka::Web::Tracking::Producers::Listeners::Booting

Inherits:
Base
  • Object
show all
Defined in:
lib/karafka/web/tracking/producers/listeners/booting.rb

Overview

Listener needed to start schedulers and other things that we need to collect and report data. We do not want to start this when code is loaded because it may not be fork compatible that way

Instance Method Summary collapse

Instance Method Details

#on_producer_connected(_event) ⇒ Object

Starts (if needed) the Web UI tracking scheduler thread that periodically pings reporters to report needed data (when it is time).

Parameters:

  • _event (Karafka::Core::Monitoring::Event) 


16
17
18
 
# File 'lib/karafka/web/tracking/producers/listeners/booting.rb', line 16

def on_producer_connected(_event)
  ::Karafka::Web.config.tracking.scheduler.async_call
end