@Override
  public CqQuery[] getCqs() {
    CqQuery[] cqs = null;
    try {
      return toArray(getCqService().getAllCqs());
    } catch (CqException cqe) {
      if (logger.isDebugEnabled()) {
        logger.debug("Unable to getAllCqs. Error :{}", cqe.getMessage(), cqe);
      }
    }
    return cqs;
  }
Retrieve all CqQuerys created by this VM.

@return null if there are no cqs.
geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java