def send_json(self, identity, obj): self.stream.send( identity, zmq.SNDMORE ) self.stream.send_json(obj)