@Override
  public void executeCqs(String regionName) throws CqException {
    try {
      getCqService().executeAllRegionCqs(regionName);
    } catch (CqException cqe) {
      if (logger.isDebugEnabled()) {
        logger.debug("Unable to execute cqs on the specified region. Error :{}", cqe.getMessage(),
            cqe);
      }
    }
  }
Starts execution of all the continuous queries registered on the specified region for this
client. This is complementary method to stopCQs().

@see QueryService#stopCqs()

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