          logger.debug("QueueManager deleting: '%s'", name)
          del self.queues[name]
          logger.debug("QueueManager deleted: '%s'", name)
  
      def get_queue(self, name, maxsize=0):
          """ Return a queue from the manager
              If it doesn't exist, create it """
          logger.debug("QueueManager getting: '%s'", name)
          queue = self.queues.get(name, None)
          if not queue:
 
</s> remove             self.add_queue(name, maxsize)
 </s> add             self.add_queue(name, maxsize, multiprocessing_queue) </s> remove 
        if rotation is not None:
            deprecation_warning("Rotation ('-r', '--rotation')",
                                additional_info="It is not necessary for most detectors and will "
                                                "be moved to plugin config for those detectors "
                                                "that require it.")
 </s> add  </s> remove         if scale == 1.0:
            return image

 </s> add 
    def get_queue(self, name, maxsize=0, multiprocessing_queue=True):
          logger.debug("QueueManager deleting: '%s'", name)
          del self.queues[name]
          logger.debug("QueueManager deleted: '%s'", name)
  
    def get_queue(self, name, maxsize=0, multiprocessing_queue=True):
          """ Return a queue from the manager
              If it doesn't exist, create it """
          logger.debug("QueueManager getting: '%s'", name)
          queue = self.queues.get(name, None)
          if not queue:
keep keep keep keep replace keep keep keep keep keep
 Added s3fd-amd + minor fixes (#837) 
lib/queue_manager.py