lib/backburner/workers/forking.rb in backburner-0.4.6 vs lib/backburner/workers/forking.rb in backburner-1.0.0

@@ -7,10 +7,10 @@
       # @raise [Beaneater::NotConnected] If beanstalk fails to connect.
       # @example
       #   @worker.prepare
       #
       def prepare
-        self.tube_names.map! { |name| expand_tube_name(name)  }
+        self.tube_names.map! { |name| expand_tube_name(name)  }.uniq!
         log_info "Working #{tube_names.size} queues: [ #{tube_names.join(', ')} ]"
         self.connection.tubes.watch!(*self.tube_names)
       end
 
       # Starts processing new jobs indefinitely.