public CqResults newCqWithInitialResults()

in src/main/java/org/apache/geode/kafka/GeodeContext.java [107:116]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public <E> CqResults<E> newCqWithInitialResults(String name, String query,
      CqAttributes cqAttributes,
      boolean isDurable) throws ConnectException {
    try {
      CqQuery cq = clientCache.getQueryService().newCq(name, query, cqAttributes, isDurable);
      return cq.executeWithInitialResults();
    } catch (RegionNotFoundException | CqException | CqExistsException e) {
      throw new ConnectException(e);
    }
  }