module EventBus::Listeners::Manager
Public Class Methods
bind_all_listeners()
click to toggle source
# File lib/event_bus/listeners/manager.rb, line 6 def bind_all_listeners listener_configurations.each do |config| EventBus::Listener.on(config[:routing_key]) do |event, channel, delivery_info| config[:listener_class].new(channel).send(config[:method], event, delivery_info) end end end
register_listener_configuration(configuration)
click to toggle source
# File lib/event_bus/listeners/manager.rb, line 14 def register_listener_configuration(configuration) listener_configurations.push(configuration) end
Private Class Methods
listener_configurations()
click to toggle source
# File lib/event_bus/listeners/manager.rb, line 20 def listener_configurations @listener_configurations ||= [] end