utils.py 文件源码

def __init__(self, queueName):
        self._qname = queueName
        self._connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
        self._channel = self._connection.channel()
        self._channel.queue_declare(queue=queueName, durable=True)