Class: RabbitWQ::Configuration
- Inherits:
-
Servitude::Configuration
- Object
- Servitude::Configuration
- RabbitWQ::Configuration
- 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 |