Module: Julewire::Karafka::WaterdropInstaller

Defined in:
lib/julewire/karafka/waterdrop_installer.rb

Constant Summary collapse

MIDDLEWARE_INSTALL = 
Core::Integration::IvarState.new(:@julewire_karafka_waterdrop_middleware)

Class Method Summary collapse

Class Method Details

.install!(producer, configuration: Configuration.new) ⇒ Object 



9
10
11
12
13
14
15
 
# File 'lib/julewire/karafka/waterdrop_installer.rb', line 9

def install!(producer, configuration: Configuration.new)
  return false unless configuration.enabled?

  install_or_update_middleware(producer, configuration) if middleware_needed?(producer, configuration)
  install_listener(producer, configuration) if configuration.producer_events?
  producer
end