lib/tobox/worker.rb in tobox-0.4.5 vs lib/tobox/worker.rb in tobox-0.5.0

@@ -6,10 +6,10 @@
 
     def initialize(label, configuration)
       @label = label
       @wait_for_events_delay = configuration[:wait_for_events_delay]
       @handlers = configuration.handlers || {}
-      @fetcher = Fetcher.new(label, configuration)
+      @fetcher = configuration.fetcher_class.new(label, configuration)
       @finished = false
 
       return unless (message_to_arguments = configuration.arguments_handler)
 
       define_singleton_method(:message_to_arguments, &message_to_arguments)