@Override
  public void stopCqs(String regionName) throws CqException {
    try {
      getCqService().stopAllRegionCqs(regionName);
    } catch (CqException cqe) {
      if (logger.isDebugEnabled()) {
        logger.debug("Unable to stop cqs on the specified region. Error :{}", cqe.getMessage(),
            cqe);
      }
    }
  }
Stops execution of all the continuous queries registered on the specified region for this
client. 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 CQs.
geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java