class Sidekiq::EventBus::Utils
Public Instance Methods
consumers()
click to toggle source
# File lib/sidekiq/event_bus/utils.rb, line 2 def consumers Sidekiq::EventBus.config.consumers.map do |klass_name| klass_name.constantize.new end end
handle_error(exception)
click to toggle source
# File lib/sidekiq/event_bus/utils.rb, line 14 def handle_error exception unless Sidekiq::EventBus.config.error_handler.nil? Sidekiq::EventBus.config.error_handler.call(exception) end end
handle_event(event, payload)
click to toggle source
# File lib/sidekiq/event_bus/utils.rb, line 8 def handle_event event, payload consumers.each do |consumer| consumer.consume(event, payload) end end