@Override
  public void closeCqs() {
    try {
      getCqService().closeAllCqs(true);
    } catch (CqException cqe) {
      if (logger.isDebugEnabled()) {
        logger.debug("Unable to closeAll Cqs. Error :{}", cqe.getMessage(), cqe);
      }
    }
  }
Close all CQs executing in this VM, and release resources associated with executing CQs.
CqQuerys created by other VMs are unaffected.
geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java