public Object create(ClientCQ cq) {
    pool.getRITracker().addCq(cq, cq.isDurable());
    return CreateCQOp.execute(pool, cq.getName(), cq.getQueryString(), CqStateImpl.RUNNING,
        cq.isDurable(), getDataPolicy(cq));
  }
Create a continuous query on the given pool

@param cq the CQ to create on the server
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ops/ServerCQProxyImpl.java