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