org.apache.geode.cache.client.internal

Class ServerCQProxyImpl

java.lang.Object

org.apache.geode.cache.client.internal.ServerProxy

org.apache.geode.cache.client.internal.ServerCQProxyImpl

public class ServerCQProxyImpl
extends org.apache.geode.cache.client.internal.ServerProxy

Used to send CQ operations from a client to a server

Since:

GemFire 5.7

Field Summary

Fields inherited from class org.apache.geode.cache.client.internal.ServerProxy

pool

Constructor Summary

Constructors

Constructor and Description
ServerCQProxyImpl(org.apache.geode.cache.client.internal.InternalPool pool) Creates a server CQ proxy for the given pool name.
ServerCQProxyImpl(org.apache.geode.cache.client.internal.ServerProxy sp) Creates a server CQ proxy given using the same pool as that of the given server proxy.

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.geode.cache.query.internal.cq.ClientCQ cq) Does a CQ close on all relevant servers
java.lang.Object	create(org.apache.geode.cache.query.internal.cq.ClientCQ cq) Create a continuous query on the given pool
java.lang.Object	createOn(java.lang.String cqName, org.apache.geode.cache.client.internal.Connection conn, java.lang.String queryStr, int cqState, boolean isDurable, byte regionDataPolicy) Create a continuous query on the given server
org.apache.geode.cache.query.SelectResults	createWithIR(org.apache.geode.cache.query.internal.cq.ClientCQ cq) Create a continuous query on the given server and return the initial query results.
java.util.List<java.lang.String>	getAllDurableCqsFromServer()
void	stop(org.apache.geode.cache.query.internal.cq.ClientCQ cq) Does a CQ stop on all relevant servers

Methods inherited from class org.apache.geode.cache.client.internal.ServerProxy

detach, getPool, ping, query

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerCQProxyImpl

public ServerCQProxyImpl(org.apache.geode.cache.client.internal.InternalPool pool)

Creates a server CQ proxy for the given pool name.

Parameters:

pool - the pool that this proxy will use to communicate with servers

ServerCQProxyImpl

public ServerCQProxyImpl(org.apache.geode.cache.client.internal.ServerProxy sp)

Creates a server CQ proxy given using the same pool as that of the given server proxy.

Parameters:

sp - server proxy whose pool we are to use

Method Detail

create

public java.lang.Object create(org.apache.geode.cache.query.internal.cq.ClientCQ cq)

Create a continuous query on the given pool

Parameters:

cq - the CQ to create on the server

createOn

public java.lang.Object createOn(java.lang.String cqName,
                                 org.apache.geode.cache.client.internal.Connection conn,
                                 java.lang.String queryStr,
                                 int cqState,
                                 boolean isDurable,
                                 byte regionDataPolicy)

Create a continuous query on the given server

Parameters:

conn - the 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

createWithIR

public org.apache.geode.cache.query.SelectResults createWithIR(org.apache.geode.cache.query.internal.cq.ClientCQ cq)

Create a continuous query on the given server and return the initial query results.

Parameters:

cq - the CQ to create on the server

stop

public void stop(org.apache.geode.cache.query.internal.cq.ClientCQ cq)

Does a CQ stop on all relevant servers

Parameters:

cq - the CQ to stop on the server

close

public void close(org.apache.geode.cache.query.internal.cq.ClientCQ cq)

Does a CQ close on all relevant servers

Parameters:

cq - the CQ to close on the server

getAllDurableCqsFromServer

public java.util.List<java.lang.String> getAllDurableCqsFromServer()