public class CreateCQOp
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
protected static class |
CreateCQOp.CreateCQOpImpl
Note both StopCQOpImpl and CloseCQOpImpl extend this class
|
| Modifier and Type | Method and Description |
|---|---|
static java.lang.Object |
execute(org.apache.geode.cache.client.internal.ExecutablePool pool,
java.lang.String cqName,
java.lang.String queryStr,
int cqState,
boolean isDurable,
byte regionDataPolicy)
Create a continuous query on the server using connections from the given pool to communicate
with the server.
|
static java.lang.Object |
executeOn(org.apache.geode.cache.client.internal.ExecutablePool pool,
org.apache.geode.cache.client.internal.Connection conn,
java.lang.String cqName,
java.lang.String queryStr,
int cqState,
boolean isDurable,
byte regionDataPolicy)
Create a continuous query on the server using a specific connections from the given pool.
|
public static java.lang.Object execute(org.apache.geode.cache.client.internal.ExecutablePool pool,
java.lang.String cqName,
java.lang.String queryStr,
int cqState,
boolean isDurable,
byte regionDataPolicy)
pool - the pool to use to communicate with the server.cqName - name of the CQ to createqueryStr - string OQL statement to be executedcqState - int cqState to be set.isDurable - true if CQ is durableregionDataPolicy - the data policy ordinal of the regionpublic static java.lang.Object executeOn(org.apache.geode.cache.client.internal.ExecutablePool pool,
org.apache.geode.cache.client.internal.Connection conn,
java.lang.String cqName,
java.lang.String queryStr,
int cqState,
boolean isDurable,
byte regionDataPolicy)
pool - the pool to use to communicate with the server.conn - the actual connection to usecqName - name of the CQ to createqueryStr - string OQL statement to be executedcqState - int cqState to be set.isDurable - true if CQ is durableregionDataPolicy - the data policy ordinal of the region