org.apache.geode.cache.client.internal

Class CreateCQOp

java.lang.Object

org.apache.geode.cache.client.internal.CreateCQOp

public class CreateCQOp
extends java.lang.Object

Creates a CQ on a server

Since:

GemFire 5.7

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	CreateCQOp.CreateCQOpImpl Note both StopCQOpImpl and CloseCQOpImpl extend this class

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

execute

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)

Create a continuous query on the server using connections from the given pool to communicate with the server.

Parameters:

pool - the pool to use to communicate with the server.

cqName - name of the CQ to create

queryStr - string OQL statement to be executed

cqState - int cqState to be set.

isDurable - true if CQ is durable

regionDataPolicy - the data policy ordinal of the region

executeOn

public 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.

Parameters:

pool - the pool to use to communicate with the server.

conn - the actual connection to use

cqName - name of the CQ to create

queryStr - string OQL statement to be executed

cqState - int cqState to be set.

isDurable - true if CQ is durable

regionDataPolicy - the data policy ordinal of the region