queue.py 文件源码

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