public CqQuery newCq()

in src/main/java/org/apache/geode/kafka/GeodeContext.java [96:105]

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

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