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:) ⇒ Object 



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

def install!(producer, configuration:)
  install_middleware(producer, configuration) if middleware_needed?(producer, configuration)
  install_listener(producer, configuration) if configuration.producer_events?
  producer
end