def METHOD_NAME(self, msg, msg_id=None):
    vaex.asyncio.check_patch_tornado()
    if msg_id is None:
        msg_id = str(uuid.uuid4())
    self.msg_reply_futures[msg_id] = asyncio.Future()
    auth = {'token': self.token, 'token-trusted': self.token_trusted}
    msg_encoding = vaex.encoding.Encoding()
    data = vaex.encoding.serialize({'msg_id': msg_id, 'msg': msg, 'auth': auth}, msg_encoding)
    self.websocket.write_message(data, binary=True)
    return msg_id