org.apache.geode.cache.query.internal.cq

Class ClientCQImpl

java.lang.Object

org.apache.geode.cache.query.internal.cq.CqQueryImpl

org.apache.geode.cache.query.internal.cq.ClientCQImpl

All Implemented Interfaces:

org.apache.geode.cache.query.CqQuery, org.apache.geode.cache.query.internal.cq.ClientCQ, org.apache.geode.cache.query.internal.cq.InternalCqQuery

public class ClientCQImpl
extends CqQueryImpl
implements org.apache.geode.cache.query.internal.cq.ClientCQ

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.geode.cache.query.internal.cq.CqQueryImpl

CqQueryImpl.TestHook

Field Summary

Fields inherited from class org.apache.geode.cache.query.internal.cq.CqQueryImpl

cqName, cqService, cqState, isDurable, query, queryString, regionName, stats, testHook

Constructor Summary

Constructors

Constructor and Description
ClientCQImpl(CqServiceImpl cqService, java.lang.String cqName, java.lang.String queryString, org.apache.geode.cache.query.CqAttributes cqAttributes, ServerCQProxyImpl serverProxy, boolean isDurable)

Method Summary

Modifier and Type	Method and Description
protected void	cleanup() Clears the resource used by CQ.
void	close()
void	close(boolean sendRequestToServer)
void	createOn(org.apache.geode.cache.client.internal.Connection conn, boolean isDurable)
void	execute() Start or resume executing the query.
<E> org.apache.geode.cache.query.CqResults<E>	executeWithInitialResults() Start or resume executing the query.
org.apache.geode.cache.query.CqAttributes	getCqAttributes()
org.apache.geode.cache.query.CqAttributesMutator	getCqAttributesMutator()
org.apache.geode.cache.query.CqListener[]	getCqListeners()
java.lang.String	getServerCqName()
void	setProxyCache(org.apache.geode.cache.client.internal.ProxyCache proxyCache)
void	stop() Stop or pause executing the query.

Methods inherited from class org.apache.geode.cache.query.internal.cq.CqQueryImpl

getCqBaseRegion, getName, getQuery, getQueryString, getRegionName, getState, getStatistics, getVsdStats, isClosed, isClosing, isDurable, isRunning, isStopped, setCqService, setCqState, setName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

getCqBaseRegion, getName, getQueryString, getRegionName, getState, getVsdStats, isDurable, setCqService, setCqState, setName

Methods inherited from interface org.apache.geode.cache.query.CqQuery

getQuery, getStatistics, isClosed, isRunning, isStopped

Constructor Detail

ClientCQImpl

public ClientCQImpl(CqServiceImpl cqService,
                    java.lang.String cqName,
                    java.lang.String queryString,
                    org.apache.geode.cache.query.CqAttributes cqAttributes,
                    ServerCQProxyImpl serverProxy,
                    boolean isDurable)

Method Detail

getServerCqName

public java.lang.String getServerCqName()

Specified by:

getServerCqName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Specified by:

getServerCqName in class CqQueryImpl

close

public void close()
           throws org.apache.geode.cache.query.CqClosedException,
                  org.apache.geode.cache.query.CqException

Specified by:

close in interface org.apache.geode.cache.query.CqQuery

Specified by:

close in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Throws:

org.apache.geode.cache.query.CqClosedException

org.apache.geode.cache.query.CqException

close

public void close(boolean sendRequestToServer)
           throws org.apache.geode.cache.query.CqClosedException,
                  org.apache.geode.cache.query.CqException

Specified by:

close in interface org.apache.geode.cache.query.internal.cq.ClientCQ

Specified by:

close in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Throws:

org.apache.geode.cache.query.CqClosedException

org.apache.geode.cache.query.CqException

cleanup

protected void cleanup()
                throws org.apache.geode.cache.query.CqException

Clears the resource used by CQ.

Specified by:

cleanup in class CqQueryImpl

Throws:

org.apache.geode.cache.query.CqException

getCqAttributes

public org.apache.geode.cache.query.CqAttributes getCqAttributes()

Specified by:

getCqAttributes in interface org.apache.geode.cache.query.CqQuery

getCqListeners

public org.apache.geode.cache.query.CqListener[] getCqListeners()

Returns:

Returns the cqListeners.

execute

public void execute()
             throws org.apache.geode.cache.query.CqClosedException,
                    org.apache.geode.cache.query.RegionNotFoundException,
                    org.apache.geode.cache.query.CqException

Start or resume executing the query.

Specified by:

execute in interface org.apache.geode.cache.query.CqQuery

Throws:

org.apache.geode.cache.query.CqClosedException

org.apache.geode.cache.query.RegionNotFoundException

org.apache.geode.cache.query.CqException

executeWithInitialResults

public <E> org.apache.geode.cache.query.CqResults<E> executeWithInitialResults()
                                                                        throws org.apache.geode.cache.query.CqClosedException,
                                                                               org.apache.geode.cache.query.RegionNotFoundException,
                                                                               org.apache.geode.cache.query.CqException

Start or resume executing the query. Gets or updates the CQ results and returns them.

Specified by:

executeWithInitialResults in interface org.apache.geode.cache.query.CqQuery

Throws:

org.apache.geode.cache.query.CqClosedException

org.apache.geode.cache.query.RegionNotFoundException

org.apache.geode.cache.query.CqException

stop

public void stop()
          throws org.apache.geode.cache.query.CqClosedException,
                 org.apache.geode.cache.query.CqException

Stop or pause executing the query.

Specified by:

stop in interface org.apache.geode.cache.query.CqQuery

Specified by:

stop in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Throws:

org.apache.geode.cache.query.CqClosedException

org.apache.geode.cache.query.CqException

getCqAttributesMutator

public org.apache.geode.cache.query.CqAttributesMutator getCqAttributesMutator()

Specified by:

getCqAttributesMutator in interface org.apache.geode.cache.query.CqQuery

setProxyCache

public void setProxyCache(org.apache.geode.cache.client.internal.ProxyCache proxyCache)

Specified by:

setProxyCache in interface org.apache.geode.cache.query.internal.cq.ClientCQ

createOn

public void createOn(org.apache.geode.cache.client.internal.Connection conn,
                     boolean isDurable)

Specified by:

createOn in interface org.apache.geode.cache.query.internal.cq.ClientCQ