Class: RabbitWQ::Configuration

Inherits:
Servitude::Configuration
  • Object
show all
Defined in:
lib/rabbit_wq/configuration.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.defaults ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# 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

Instance Method Details

#ignored_workers_to_error_queue ⇒ Object 



28
29
30
31
 
# 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 ⇒ Object 



33
34
35
36
 
# File 'lib/rabbit_wq/configuration.rb', line 33

def ignored_workers_trash
  return [] unless ignored_workers
  Array( ignored_workers.trash )
end