class Sidekiq::EventBus::Configuration

Attributes

adapter[RW]
consumers[RW]
error_handler[RW]
sidekiq_worker_options[RW]

Public Class Methods

new() click to toggle source
# File lib/sidekiq/event_bus/configuration.rb, line 4
def initialize
  self.adapter                = Sidekiq::EventBus::Adapters::Default.new
  self.consumers              = Set.new
  self.sidekiq_worker_options = { retry: 0, dead: true }
end

Public Instance Methods

register_consumer(klass) click to toggle source
# File lib/sidekiq/event_bus/configuration.rb, line 10
def register_consumer klass
  klass = klass.name unless klass.is_a?(String)
  consumers << klass
end