rabbitmq.py 文件源码

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

项目:Url 作者: beiruan 项目源码 文件源码
def reconnect(self):
        """Reconnect to rabbitmq server"""
        import pika
        import pika.exceptions

        self.connection = pika.BlockingConnection(pika.URLParameters(self.amqp_url))
        self.channel = self.connection.channel()
        try:
            self.channel.queue_declare(self.name)
        except pika.exceptions.ChannelClosed:
            self.connection = pika.BlockingConnection(pika.URLParameters(self.amqp_url))
            self.channel = self.connection.channel()
        #self.channel.queue_purge(self.name)
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号