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

Class CqAttributesMutatorImpl

java.lang.Object

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

All Implemented Interfaces:

org.apache.geode.cache.query.CqAttributesMutator

public class CqAttributesMutatorImpl
extends java.lang.Object
implements org.apache.geode.cache.query.CqAttributesMutator

Supports modification of certain cq attributes after the cq has been created. The setter methods all return the previous value of the attribute.

Since:

GemFire 5.5

Constructor Summary

Constructors

Constructor and Description
CqAttributesMutatorImpl()

Method Summary

Modifier and Type	Method and Description
void	addCqListener(org.apache.geode.cache.query.CqListener aListener) Adds a cq listener to the end of the list of cq listeners on this CqQuery.
void	initCqListeners(org.apache.geode.cache.query.CqListener[] newListeners) Removes all cq listeners, calling on each of them, and then adds each listener in the specified array.
void	removeCqListener(org.apache.geode.cache.query.CqListener aListener) Removes a cq listener from the list of cq listeners on this CqQuery.

Methods inherited from class java.lang.Object

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

Constructor Detail

CqAttributesMutatorImpl

public CqAttributesMutatorImpl()

Method Detail

addCqListener

public void addCqListener(org.apache.geode.cache.query.CqListener aListener)

Adds a cq listener to the end of the list of cq listeners on this CqQuery.

Specified by:

addCqListener in interface org.apache.geode.cache.query.CqAttributesMutator

Parameters:

aListener - the user defined cq listener to add to the CqQuery.

Throws:

java.lang.IllegalArgumentException - if aListener is null

removeCqListener

public void removeCqListener(org.apache.geode.cache.query.CqListener aListener)

Removes a cq listener from the list of cq listeners on this CqQuery. Does nothing if the specified listener has not been added. If the specified listener has been added then CacheCallback.close() will be called on it; otherwise does nothing.

Specified by:

removeCqListener in interface org.apache.geode.cache.query.CqAttributesMutator

Parameters:

aListener - the cq listener to remove from the CqQuery.

Throws:

java.lang.IllegalArgumentException - if aListener is null

initCqListeners

public void initCqListeners(org.apache.geode.cache.query.CqListener[] newListeners)

Removes all cq listeners, calling on each of them, and then adds each listener in the specified array.

Specified by:

initCqListeners in interface org.apache.geode.cache.query.CqAttributesMutator

Parameters:

newListeners - a possibly null or empty array of listeners to add to this CqQuery.

Throws:

java.lang.IllegalArgumentException - if the newListeners array has a null element