old_contents: class AMQPMixin(object):
  
      amqp_setup = False
  
      def setupAMQP(self, config):
          if not self.amqp_setup:
              # Create AMQP Connection
              # AMQP connection parameters
              self.amqp_host = config["amqp_host"]
              self.amqp_port = config.get("amqp_port", 5672)
              self.amqp_username = config["amqp_username"]
              self.amqp_password = config["amqp_password"]
              self.amqp_queue = config["amqp_queue"]
              self.amqp_exchange = config["amqp_exchange"]
              self.amqp_prefetch_count = 100
              self.amqp_setup = True
  
new_contents: class AMQPMixin(object):
  
      amqp_setup = False
  
      def setupAMQP(self, config):
          if not self.amqp_setup:
              # Create AMQP Connection
              # AMQP connection parameters
              self.amqp_host = config["amqp_host"]
              self.amqp_port = config.get("amqp_port", 5672)
              self.amqp_username = config["amqp_username"]
              self.amqp_password = config["amqp_password"]
              self.amqp_queue = config["amqp_queue"]
              self.amqp_exchange = config["amqp_exchange"]
              self.amqp_prefetch_count = 1000
              self.amqp_setup = True
  
subject: Set prefetch count to 1000.