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

Class CqServiceImpl

java.lang.Object

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

All Implemented Interfaces:

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

public class CqServiceImpl
extends java.lang.Object
implements org.apache.geode.cache.query.internal.cq.CqService

Implements the CqService functionality.

Since:

GemFire 5.5

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	EXECUTE_QUERY_DURING_INIT System property to evaluate the query even though the initial results are not required when cq is executed using the execute() method.

Constructor Summary

Constructors

Constructor and Description
CqServiceImpl(org.apache.geode.internal.cache.InternalCache cache) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up the CqService.
void	closeAllCqs(boolean clientInitiated)
void	closeAllCqs(boolean clientInitiated, java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> cqs, boolean keepAlive)
void	closeClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
void	closeCq(java.lang.String cqName, org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
void	closeCqs(java.lang.String regionName)
void	closeNonDurableClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId) Server side method.
java.lang.String	constructServerCqName(java.lang.String cqName, org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
void	cqsConnected(org.apache.geode.cache.client.Pool pool)
void	cqsDisconnected(org.apache.geode.cache.client.Pool pool)
void	dispatchCqListeners(java.util.HashMap<java.lang.String,java.lang.Integer> cqs, int messageType, java.lang.Object key, java.lang.Object value, byte[] delta, org.apache.geode.cache.client.internal.QueueManager qManager, org.apache.geode.internal.cache.EventID eventId)
void	executeAllClientCqs()
void	executeAllRegionCqs(java.lang.String regionName)
org.apache.geode.cache.query.internal.cq.ServerCQ	executeCq(java.lang.String cqName, java.lang.String queryString, int cqState, org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId, org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier ccn, boolean isDurable, boolean manageEmptyRegions, int regionDataPolicy, java.util.Map emptyRegionsMap) Executes the given CqQuery, if the CqQuery for that name is not there it registers the one and executes.
void	executeCqs(java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> cqs)
java.util.List<org.apache.geode.cache.query.internal.cq.ServerCQ>	getAllClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery>	getAllCqs()
java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery>	getAllCqs(java.lang.String regionName)
java.util.List<java.lang.String>	getAllDurableClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
java.util.List<java.lang.String>	getAllDurableCqsFromServer(org.apache.geode.cache.client.internal.InternalPool pool)
org.apache.geode.cache.Cache	getCache() Returns the cache associated with the cqService.
org.apache.geode.cache.query.CqQuery	getClientCqFromServer(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId, java.lang.String clientCqName)
org.apache.geode.cache.query.internal.cq.InternalCqQuery	getCq(java.lang.String cqName)
CqServiceVsdStats	getCqServiceVsdStats() Get the VSD ststs for CQ Service.
org.apache.geode.cache.query.CqServiceStatistics	getCqStatistics()
org.apache.geode.internal.cache.InternalCache	getInternalCache()
java.util.Map<java.lang.String,java.util.HashSet<java.lang.String>>	getMatchingCqMap() Returns the matching CQ map.
org.apache.geode.cache.client.internal.UserAttributes	getUserAttributes(java.lang.String cqName)
boolean	isRunning()
boolean	isServer() Is the CQ service in a cache server environment
org.apache.geode.cache.query.internal.cq.ClientCQ	newCq(java.lang.String cqName, java.lang.String queryString, org.apache.geode.cache.query.CqAttributes cqAttributes, org.apache.geode.cache.client.internal.InternalPool pool, boolean isDurable)
void	processEvents(org.apache.geode.cache.CacheEvent event, org.apache.geode.distributed.internal.DistributionAdvisor.Profile localProfile, org.apache.geode.distributed.internal.DistributionAdvisor.Profile[] profiles, org.apache.geode.internal.cache.FilterRoutingInfo frInfo)
void	resumeCQ(int cqState, org.apache.geode.cache.query.internal.cq.ServerCQ cQuery)
void	start()
CqServiceVsdStats	stats()
void	stopAllClientCqs()
void	stopAllRegionCqs(java.lang.String regionName)
void	stopCq(java.lang.String cqName, org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientId) Called directly on server side.
void	stopCqs(java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> cqs)

Methods inherited from class java.lang.Object

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

Field Detail

EXECUTE_QUERY_DURING_INIT

public static boolean EXECUTE_QUERY_DURING_INIT

System property to evaluate the query even though the initial results are not required when cq is executed using the execute() method.

Constructor Detail

CqServiceImpl

public CqServiceImpl(org.apache.geode.internal.cache.InternalCache cache)

Constructor.

Parameters:

cache - The cache used for the service

Method Detail

getCache

public org.apache.geode.cache.Cache getCache()

Returns the cache associated with the cqService.

getInternalCache

public org.apache.geode.internal.cache.InternalCache getInternalCache()

stats

public CqServiceVsdStats stats()

newCq

public org.apache.geode.cache.query.internal.cq.ClientCQ newCq(java.lang.String cqName,
                                                               java.lang.String queryString,
                                                               org.apache.geode.cache.query.CqAttributes cqAttributes,
                                                               org.apache.geode.cache.client.internal.InternalPool pool,
                                                               boolean isDurable)
                                                        throws org.apache.geode.cache.query.QueryInvalidException,
                                                               org.apache.geode.cache.query.CqExistsException,
                                                               org.apache.geode.cache.query.CqException

Specified by:

newCq in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.QueryInvalidException

org.apache.geode.cache.query.CqExistsException

org.apache.geode.cache.query.CqException

executeCq

public org.apache.geode.cache.query.internal.cq.ServerCQ executeCq(java.lang.String cqName,
                                                                   java.lang.String queryString,
                                                                   int cqState,
                                                                   org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId,
                                                                   org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier ccn,
                                                                   boolean isDurable,
                                                                   boolean manageEmptyRegions,
                                                                   int regionDataPolicy,
                                                                   java.util.Map emptyRegionsMap)
                                                            throws org.apache.geode.cache.query.CqException,
                                                                   org.apache.geode.cache.query.RegionNotFoundException,
                                                                   org.apache.geode.cache.query.CqClosedException

Executes the given CqQuery, if the CqQuery for that name is not there it registers the one and executes. This is called on the Server.

Specified by:

executeCq in interface org.apache.geode.cache.query.internal.cq.CqService

Parameters:

manageEmptyRegions - whether to update the 6.1 emptyRegions map held in the CCN

regionDataPolicy - the data policy of the region associated with the query. This is only needed if manageEmptyRegions is true.

emptyRegionsMap - map of empty regions.

Throws:

java.lang.IllegalStateException - if this is called at client side.

org.apache.geode.cache.query.CqException

org.apache.geode.cache.query.RegionNotFoundException

org.apache.geode.cache.query.CqClosedException

resumeCQ

public void resumeCQ(int cqState,
                     org.apache.geode.cache.query.internal.cq.ServerCQ cQuery)

Specified by:

resumeCQ in interface org.apache.geode.cache.query.internal.cq.CqService

getClientCqFromServer

public org.apache.geode.cache.query.CqQuery getClientCqFromServer(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId,
                                                                  java.lang.String clientCqName)

Specified by:

getClientCqFromServer in interface org.apache.geode.cache.query.internal.cq.CqService

getCq

public org.apache.geode.cache.query.internal.cq.InternalCqQuery getCq(java.lang.String cqName)

Specified by:

getCq in interface org.apache.geode.cache.query.internal.cq.CqService

getAllCqs

public java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> getAllCqs()

Specified by:

getAllCqs in interface org.apache.geode.cache.query.internal.cq.CqService

getAllCqs

public java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> getAllCqs(java.lang.String regionName)
                                                                                                   throws org.apache.geode.cache.query.CqException

Specified by:

getAllCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

executeAllClientCqs

public void executeAllClientCqs()
                         throws org.apache.geode.cache.query.CqException

Specified by:

executeAllClientCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

executeAllRegionCqs

public void executeAllRegionCqs(java.lang.String regionName)
                         throws org.apache.geode.cache.query.CqException

Specified by:

executeAllRegionCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

executeCqs

public void executeCqs(java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> cqs)
                throws org.apache.geode.cache.query.CqException

Specified by:

executeCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

stopAllClientCqs

public void stopAllClientCqs()
                      throws org.apache.geode.cache.query.CqException

Specified by:

stopAllClientCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

stopAllRegionCqs

public void stopAllRegionCqs(java.lang.String regionName)
                      throws org.apache.geode.cache.query.CqException

Specified by:

stopAllRegionCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

stopCqs

public void stopCqs(java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> cqs)
             throws org.apache.geode.cache.query.CqException

Specified by:

stopCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

closeCqs

public void closeCqs(java.lang.String regionName)
              throws org.apache.geode.cache.query.CqException

Specified by:

closeCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

stopCq

public void stopCq(java.lang.String cqName,
                   org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientId)
            throws org.apache.geode.cache.query.CqException

Called directly on server side.

Specified by:

stopCq in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

closeCq

public void closeCq(java.lang.String cqName,
                    org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
             throws org.apache.geode.cache.query.CqException

Specified by:

closeCq in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

closeAllCqs

public void closeAllCqs(boolean clientInitiated)

Specified by:

closeAllCqs in interface org.apache.geode.cache.query.internal.cq.CqService

closeAllCqs

public void closeAllCqs(boolean clientInitiated,
                        java.util.Collection<? extends org.apache.geode.cache.query.internal.cq.InternalCqQuery> cqs,
                        boolean keepAlive)

Specified by:

closeAllCqs in interface org.apache.geode.cache.query.internal.cq.CqService

getCqStatistics

public org.apache.geode.cache.query.CqServiceStatistics getCqStatistics()

Specified by:

getCqStatistics in interface org.apache.geode.cache.query.internal.cq.CqService

closeClientCqs

public void closeClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
                    throws org.apache.geode.cache.query.CqException

Specified by:

closeClientCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

getAllClientCqs

public java.util.List<org.apache.geode.cache.query.internal.cq.ServerCQ> getAllClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)

Specified by:

getAllClientCqs in interface org.apache.geode.cache.query.internal.cq.CqService

getAllDurableClientCqs

public java.util.List<java.lang.String> getAllDurableClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
                                                        throws org.apache.geode.cache.query.CqException

Specified by:

getAllDurableClientCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

closeNonDurableClientCqs

public void closeNonDurableClientCqs(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)
                              throws org.apache.geode.cache.query.CqException

Server side method. Closes non-durable CQs for the given client proxy id.

Specified by:

closeNonDurableClientCqs in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

isServer

public boolean isServer()

Is the CQ service in a cache server environment

Returns:

true if cache server, false otherwise

close

public void close()

Cleans up the CqService.

Specified by:

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

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.apache.geode.cache.query.internal.cq.CqService

start

public void start()

Specified by:

start in interface org.apache.geode.cache.query.internal.cq.CqService

constructServerCqName

public java.lang.String constructServerCqName(java.lang.String cqName,
                                              org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId)

Specified by:

constructServerCqName in interface org.apache.geode.cache.query.internal.cq.CqService

Returns:

Returns the serverCqName.

dispatchCqListeners

public void dispatchCqListeners(java.util.HashMap<java.lang.String,java.lang.Integer> cqs,
                                int messageType,
                                java.lang.Object key,
                                java.lang.Object value,
                                byte[] delta,
                                org.apache.geode.cache.client.internal.QueueManager qManager,
                                org.apache.geode.internal.cache.EventID eventId)

Specified by:

dispatchCqListeners in interface org.apache.geode.cache.query.internal.cq.CqService

processEvents

public void processEvents(org.apache.geode.cache.CacheEvent event,
                          org.apache.geode.distributed.internal.DistributionAdvisor.Profile localProfile,
                          org.apache.geode.distributed.internal.DistributionAdvisor.Profile[] profiles,
                          org.apache.geode.internal.cache.FilterRoutingInfo frInfo)
                   throws org.apache.geode.cache.query.CqException

Specified by:

processEvents in interface org.apache.geode.cache.query.internal.cq.CqService

Throws:

org.apache.geode.cache.query.CqException

getCqServiceVsdStats

public CqServiceVsdStats getCqServiceVsdStats()

Get the VSD ststs for CQ Service. There is one CQ Service per cache

Returns:

reference to VSD stats object for the CQ service

getMatchingCqMap

public java.util.Map<java.lang.String,java.util.HashSet<java.lang.String>> getMatchingCqMap()

Returns the matching CQ map.

Returns:

HashMap matchingCqMap

getUserAttributes

public org.apache.geode.cache.client.internal.UserAttributes getUserAttributes(java.lang.String cqName)

Specified by:

getUserAttributes in interface org.apache.geode.cache.query.internal.cq.CqService

cqsDisconnected

public void cqsDisconnected(org.apache.geode.cache.client.Pool pool)

Specified by:

cqsDisconnected in interface org.apache.geode.cache.query.internal.cq.CqService

cqsConnected

public void cqsConnected(org.apache.geode.cache.client.Pool pool)

Specified by:

cqsConnected in interface org.apache.geode.cache.query.internal.cq.CqService

getAllDurableCqsFromServer

public java.util.List<java.lang.String> getAllDurableCqsFromServer(org.apache.geode.cache.client.internal.InternalPool pool)

Specified by:

getAllDurableCqsFromServer in interface org.apache.geode.cache.query.internal.cq.CqService