rabbitmq.py 文件源码

python
阅读 25 收藏 0 点赞 0 评论 0

项目:globomap-driver-napi 作者: globocom 项目源码 文件源码
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()
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号