__init__.py 文件源码

def init():
        logger.info("Initializing queue manager")
        base = "amqp://{username}:{password}@{host}:{port}"
        params = pika.URLParameters(base.format(username=config.rabbit_mq_user, password=config.rabbit_mq_pass,
                                                host=config.rabbit_mq_url, port=config.rabbit_mq_port))
        QueueWrapper.connection = pika.BlockingConnection(params)
        QueueWrapper.channel = QueueWrapper.connection.channel()
        QueueWrapper.channel.basic_qos(prefetch_count=1)
        QueueWrapper.existing_queues = set()
        QueueWrapper.existing_queues_lock = threading.Lock()