Method: Toiler.active_worker_class_registry

Defined in:
lib/toiler.rb

.active_worker_class_registry ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/toiler.rb', line 41

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