def run()

in sample/scenarios/queue_multi_thread.py [0:0]

• 15 lines of code
• 4 McCabe index (conditional complexity)

    def run(self):
        print("%sSend Message To Queue%s\nQueueName: %s\nMessageCount: %s\nThreadName: %s"
              % (10 * "=", 10 * "=", self.queue_name, self.msg_count, self.name))
        for j in range(self.msg_count):
            try:
                msg_body = u"I am test message %s-%s." % (self.name, j)
                msg = Message(msg_body)
                re_msg = self.queue.send_message(msg)
                print("Send Message Succeed! MessageBody: %s MessageID: %s"
                      % (msg_body, re_msg.message_id))
            except MNSExceptionBase as e:
                if e.type == "QueueNotExist":
                    print("Queue not exist, please create queue before send message.")
                    sys.exit(0)
                print("Send Message Fail! Exception:%s\n" % e)