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

@see QueryService#stopCqs()

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