void removeFromCqMap() throws CqException {
    try {
      cqService.removeCq(getServerCqName());
    } catch (Exception ex) {
      String errMsg =
          "Failed to remove Continuous Query From the repository. CqName: %s Error : %s";
      Object[] errMsgArgs = new Object[] {cqName, ex.getLocalizedMessage()};
      String msg = String.format(errMsg, errMsgArgs);
      logger.error(msg);
      throw new CqException(msg, ex);
    }
    if (logger.isDebugEnabled()) {
      logger.debug("Removed CQ from the CQ repository. CQ Name: {}", cqName);
    }
  }
Removes the CQ from CQ repository.
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqQueryImpl.java