public static Object executeOn(final @NotNull ExecutablePool pool, final @NotNull Connection conn,
      final @NotNull String cqName,
      final @NotNull String queryStr, final int cqState, final boolean isDurable,
      final @NotNull DataPolicy regionDataPolicy) {
    AbstractOp op = new CreateCQOpImpl(cqName, queryStr, cqState, isDurable, regionDataPolicy);
    return pool.executeOn(conn, op);
  }
Create a continuous query on the server using a specific connections from the given pool.

@param pool the pool to use to communicate with the server.
@param conn the actual connection to use
@param cqName name of the CQ to create
@param queryStr string OQL statement to be executed
@param cqState int cqState to be set.
@param isDurable true if CQ is durable
@param regionDataPolicy the data policy ordinal of the region
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ops/CreateCQOp.java