class MultipleMan::Configuration

Attributes

app_name[RW]
bunny_opts[RW]
connection[RW]
connection_recovery[RW]
enabled[RW]
error_handler[RW]
exchange_opts[RW]
logger[W]
prefetch_size[RW]
publisher_confirms[RW]
queue_name[RW]
reraise_errors[RW]
subscriber_registry[R]
topic_name[RW]
tracer[W]
worker_concurrency[RW]

Public Class Methods

new() click to toggle source
# File lib/multiple_man/configuration.rb, line 19
def initialize
  self.topic_name = "multiple_man"
  self.app_name = Rails.application.class.parent.to_s if defined?(Rails)
  self.enabled = true
  self.worker_concurrency = 1
  self.reraise_errors = true
  self.prefetch_size = 100
  self.connection_recovery = {
    time_before_reconnect: 0.2,
    time_between_retries: 0.8,
    max_retries: 5
  }
  self.bunny_opts = {}
  self.exchange_opts = {}
  self.publisher_confirms = false

  @subscriber_registry = Subscribers::Registry.new
end

Public Instance Methods

listeners() click to toggle source
# File lib/multiple_man/configuration.rb, line 54
def listeners
  subscriber_registry.subscriptions
end
logger() click to toggle source
# File lib/multiple_man/configuration.rb, line 42
def logger
  @logger ||= defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end
on_error(&block) click to toggle source
# File lib/multiple_man/configuration.rb, line 50
def on_error(&block)
  @error_handler = block
end
register_listener(listener) click to toggle source
# File lib/multiple_man/configuration.rb, line 58
def register_listener(listener)
  subscriber_registry.register(listener)
end
tracer() click to toggle source
# File lib/multiple_man/configuration.rb, line 46
def tracer
  @tracer ||= ::MultipleMan::Tracers::NullTracer
end