def __init__(self, host, port, user, password, vhost, queue_name):
credentials = pika.PlainCredentials(user, password)
parameters = pika.ConnectionParameters(
host=host, port=port,
virtual_host=vhost, credentials=credentials
)
self.queue_name = queue_name
self.connection = pika.BlockingConnection(parameters)
self.channel = self.connection.channel()
self.channel.confirm_delivery()
评论列表
文章目录