__init__.py 文件源码

def connect(self, ):
        aps = pika.URLParameters(self.auri)
        while 1:
            try:
                rc = pika.BlockingConnection(aps)
            except:
                print "Retry connect to mq center for in seconds"
                time.sleep(5)
                continue
            break
        return rc