@Override
  public void stopCqs() throws CqException {
    try {
      getCqService().stopAllClientCqs();
    } catch (CqException cqe) {
      if (logger.isDebugEnabled()) {
        logger.debug("Unable to stop all CQs. Error :{}", cqe.getMessage(), cqe);
      }
    }
  }
Stops execution of all the continuous queries for this client to become inactive. This is
useful when client needs to control the incoming cq messages during bulk region operations.

@see QueryService#executeCqs()

@throws CqException if failure to execute CQ.
geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java