lib/toiler/actor/processor.rb in toiler-0.5.1.pre1 vs lib/toiler/actor/processor.rb in toiler-0.5.1.pre2

@@ -11,17 +11,20 @@
                     :extend_callback, :executing, :thread
 
       def initialize(queue)
         @queue = queue
         @worker_class = Toiler.worker_class_registry[queue]
-        @fetcher = Toiler.fetcher queue
         @executing = Concurrent::AtomicBoolean.new
         @thread = nil
         init_options
       end
 
       def default_executor
         Concurrent.global_io_executor
+      end
+
+      def fetcher
+        @fetcher ||= Toiler.fetcher queue
       end
 
       def on_message(msg)
         method, *args = msg
         send(method, *args)