python 申明队列的方法

#!/usr/bin/env pythonimport pikaif __name__ == '__main__':credentials = pika.PlainCredentials('guest', 'guest')parameters = pika.ConnectionParameters(host='192.168.2.143', port='5672',...

拼命小孩

442人浏览 · 2019-10-21 18:41:41

拼命小孩 · 2019-10-21 18:41:41 发布

#!/usr/bin/env python
import pika

if __name__ == '__main__':
    credentials = pika.PlainCredentials('guest', 'guest')
    parameters = pika.ConnectionParameters(host='192.168.2.143', port='5672',
                                           credentials=credentials,
                                           heartbeat=15, retry_delay=5)
    connection = pika.BlockingConnection(parameters)
    channel = connection.channel()
    channel.queue_declare(queue= 'weipengfeitest', durable=True, exclusive=False, auto_delete=False)
    channel.queue_bind(queue= 'weipengfeitest', exchange= 'ZRTZ_EXCHANGE_EFENCE', routing_key= 'weipengfeitest')