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