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_h()
Alias for: to_hsh
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