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