code: def start(self):
          
          if not self.connection:
              self.create_connection()
          while True:
              try:
                  channel = self.connection.channel()
                  channel.queue.declare('simple_queue')
                  channel.basic.consume(self, 'simple_queue', no_ack=False)
                  channel.start_consuming()
                  if not channel.consumer_tags:
                      channel.close()
              except amqpstorm.AMQPError as why:
                  LOGGER.exception(why)
                  self.create_connection()
              except KeyboardInterrupt:
                  self.connection.close()
                  break
docs: Start the Consumers.
  
          :return: