class RabbitWQ::Configuration

Public Class Methods

defaults() click to toggle source
# File lib/rabbit_wq/configuration.rb, line 6
def self.defaults
  {
    delayed_exchange_prefix: 'work-delay',
    delayed_queue_prefix: 'work-delay',
    env: 'production',
    error_queue: 'work-error',
    log: "/var/log/rabbit-wq/#{RabbitWQ.process_name}.log",
    log_level: 'info',
    pid: "/var/run/rabbit-wq/#{RabbitWQ.process_name}.pid",
    prefetch: 50,
    supervision_retry_timeout_in_seconds: 1,
    threads: 1,
    time_zone: 'UTC',
    work_exchange: 'work',
    work_exchange_type: 'fanout',
    work_log_level: 'info',
    work_log_path: '/var/log/rabbit-wq/rabbit-wq-work.log',
    work_publish_queue: 'work',
    work_subscribe_queue: 'work'
  }
end

Public Instance Methods

ignored_workers_to_error_queue() click to toggle source
# File lib/rabbit_wq/configuration.rb, line 28
def ignored_workers_to_error_queue
  return [] unless ignored_workers
  Array( ignored_workers.to_error_queue )
end
ignored_workers_trash() click to toggle source
# File lib/rabbit_wq/configuration.rb, line 33
def ignored_workers_trash
  return [] unless ignored_workers
  Array( ignored_workers.trash )
end