lib/toiler/actor/supervisor.rb in toiler-0.4.1 vs lib/toiler/actor/supervisor.rb in toiler-0.4.2

@@ -17,16 +17,12 @@
 
       def on_message(_msg)
         pass
       end
 
-      def queues
-        Toiler.worker_class_registry
-      end
-
       def spawn_fetchers
-        queues.each do |queue, _klass|
+        Toiler.active_worker_class_registry.each do |queue, _klass|
           begin
             fetcher = Actor::Fetcher.spawn! name: "fetcher_#{queue}".to_sym,
                                             supervise: true, args: [queue, client]
             Toiler.set_fetcher queue, fetcher
           rescue StandardError => e
@@ -34,10 +30,10 @@
           end
         end
       end
 
       def spawn_processors
-        queues.each do |queue, klass|
+        Toiler.active_worker_class_registry.each do |queue, klass|
           name = "processor_pool_#{queue}".to_sym
           count = klass.concurrency
           begin
             pool = Concurrent::Actor::Utils::Pool.spawn! name, count do |index|
                 Actor::Processor.spawn name: "processor_#{queue}_#{index}".to_sym,