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