@Override
  public void createOn(Connection conn, boolean isDurable) {
    final DataPolicy regionDataPolicy = getCqBaseRegion() == null ? DataPolicy.EMPTY
        : getCqBaseRegion().getAttributes().getDataPolicy();

    int state = cqState.getState();
    cqProxy.createOn(getName(), conn, getQueryString(), state, isDurable, regionDataPolicy);
  }
Stop or pause executing the query.
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ClientCQImpl.java