class Emque::Consuming::Configuration
Attributes
adapter[RW]
app_name[RW]
auto_shutdown[RW]
delayed_message_workers[RW]
enable_delayed_message[RW]
env[W]
error_expiration[RW]
error_handlers[RW]
error_limit[RW]
log_formatter[W]
log_level[W]
retryable_error_limit[RW]
retryable_errors[RW]
shutdown_handlers[RW]
socket_path[RW]
status[RW]
status_host[RW]
status_port[RW]
Public Class Methods
new()
click to toggle source
# File lib/emque/consuming/configuration.rb, line 13 def initialize @app_name = "" @auto_shutdown = false @delayed_message_workers = 1 @enable_delayed_message = false @error_handlers = [] @error_limit = 5 @error_expiration = 3600 # 60 minutes @log_level = nil @log_formatter = nil @retryable_errors = [] @retryable_error_limit = 3 @status_port = 10000 @status_host = "0.0.0.0" @status = :off # :on @socket_path = "tmp/emque.sock" @shutdown_handlers = [] end
Public Instance Methods
env()
click to toggle source
# File lib/emque/consuming/configuration.rb, line 32 def env Emque::Consuming.application.emque_env end
env_var()
click to toggle source
# File lib/emque/consuming/configuration.rb, line 36 def env_var @env end
log_formatter()
click to toggle source
# File lib/emque/consuming/configuration.rb, line 44 def log_formatter @log_formatter ||= ::Logger::Formatter.new end
log_level()
click to toggle source
# File lib/emque/consuming/configuration.rb, line 40 def log_level @log_level ||= Logger::INFO end
set_adapter(name, options = {})
click to toggle source
# File lib/emque/consuming/configuration.rb, line 48 def set_adapter(name, options = {}) @adapter = Emque::Consuming::Adapter.new(name, options) end
to_hsh()
click to toggle source
# File lib/emque/consuming/configuration.rb, line 52 def to_hsh {}.tap { |config| [ :app_name, :adapter, :auto_shutdown, :delayed_message_workers, :env, :enable_delayed_message, :error_handlers, :error_limit, :error_expiration, :log_level, :retryable_errors, :retryable_error_limit, :status_port, :status_host, :status, :socket_path, :shutdown_handlers ].each { |attr| config[attr] = send(attr) } } end
Also aliased as: to_h