mflow.py 文件源码

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

项目:mflow 作者: datastreaming 项目源码 文件源码
def send(self, message, send_more=False, block=True, as_json=False):

        flags = 0
        if send_more:
            flags = zmq.SNDMORE
        if not block:
            flags = flags | zmq.NOBLOCK

        try:
            if as_json:
                self.socket.send_json(message, flags)
            else:
                self.socket.send(message, flags, copy=self.zmq_copy, track=self.zmq_track)
        except zmq.Again as e:
            if not block:
                pass
            else:
                raise e
        except zmq.ZMQError as e:
            logger.error(sys.exc_info()[1])
            raise e
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号