python rabbitMQ持久化队列消息

import pika
connection = pika.BlockingConnection(
    pika.ConnectionParameters('localhost'))#建立一个最基本的socket
chanel = connection.channel()#声明一个管道

chanel.queue_declare(queue='name1',durable=True)#给管道创建一个队列，参数是管道队列名。
#持久化队列
chanel.basic_publish(exchange='',
                     routing_key='name1',
                     body ='HELLO WORD!',
                     properties=pika.BasicProperties(
                         delivery_mode=2))#彻底将队列中的信息持久化。
print( '发出一个消息')
connection.close()#关闭