@Override
  public CqQuery getCq(String cqName) {
    CqQuery cq = null;
    try {
      cq = getCqService().getCq(cqName);
    } catch (CqException cqe) {
      if (logger.isDebugEnabled()) {
        logger.debug("Unable to getCq. Error :{}", cqe.getMessage(), cqe);
      }
    }
    return cq;
  }
Retrieve a CqQuery by name.

@return the CqQuery or null if not found
geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java