async def METHOD_NAME(self, websocket_msg):
    try:
        await self._handle_message(websocket_msg)
    except BaseException as e:
        encoding = Encoding()
        websocket_msg = deserialize(websocket_msg, encoding)
        msg_id = websocket_msg['msg_id']
        msg = exception(e)
        await self.write_json({'msg_id': msg_id, 'msg': msg})
        logger.exception("unhandled exception")