public void createOn(final @NotNull String cqName, final @NotNull Connection conn,
      final @NotNull String queryStr, final int cqState,
      final boolean isDurable, final @NotNull DataPolicy regionDataPolicy) {

    CreateCQOp.executeOn(pool, conn, cqName, queryStr, cqState, isDurable, regionDataPolicy);
  }
Create a continuous query on the given server

@param conn the 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/ServerCQProxyImpl.java