module Toiler
Main module
Toiler
Version
Constants
- VERSION
Attributes
fetchers[R]
options[R]
processor_pools[R]
worker_class_registry[R]
fetchers[R]
options[R]
processor_pools[R]
worker_class_registry[R]
Public Instance Methods
active_worker_class_registry()
click to toggle source
# File lib/toiler.rb, line 31 def active_worker_class_registry active_queues = options[:active_queues] if active_queues active_queues.each_with_object({}) do |q, registry| worker = @worker_class_registry[q] if worker.nil? logger.warn "No worker assigned to queue: #{q}" else registry[q] = worker end end else @worker_class_registry end end
default_options()
click to toggle source
# File lib/toiler.rb, line 63 def default_options { auto_visibility_timeout: false, concurrency: 1, auto_delete: false, shutdown_timeout: 5, batch: false } end
fetcher(queue)
click to toggle source
# File lib/toiler.rb, line 47 def fetcher(queue) fetchers["fetcher_#{queue}".to_sym] end
logger()
click to toggle source
# File lib/toiler.rb, line 23 def logger Toiler::Utils::Logging.logger end
processor_pool(queue)
click to toggle source
# File lib/toiler.rb, line 55 def processor_pool(queue) processor_pools["processor_pool_#{queue}".to_sym] end
queues()
click to toggle source
# File lib/toiler.rb, line 27 def queues worker_class_registry.keys end
register_worker(queue, worker)
click to toggle source
# File lib/toiler.rb, line 73 def register_worker(queue, worker) @worker_class_registry[queue] = worker end
set_fetcher(queue, val)
click to toggle source
# File lib/toiler.rb, line 51 def set_fetcher(queue, val) fetchers["fetcher_#{queue}".to_sym] = val end
set_processor_pool(queue, val)
click to toggle source
# File lib/toiler.rb, line 59 def set_processor_pool(queue, val) processor_pools["processor_pool_#{queue}".to_sym] = val end
worker_class_registry=(val)
click to toggle source
# File lib/toiler.rb, line 77 def worker_class_registry=(val) @worker_class_registry = val end