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