def start():
""" Start cntl server. """
connection = pika.BlockingConnection(
pika.ConnectionParameters(host=CONF['rpc']['address']))
channel = connection.channel()
channel.queue_declare(queue=CONF['os_info']['REGION_NAME'])
channel.basic_consume(handle,
queue=CONF['os_info']['REGION_NAME'],
no_ack=True)
channel.start_consuming()
评论列表
文章目录