async def METHOD_NAME(self, message):
    try:
        self.tornado_handler.write_message(
            message, binary=isinstance(message, bytes))
    except tornado.websocket.WebSocketClosedError:
        raise exceptions.EngineIOError()