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

Class CqListenerImpl

java.lang.Object

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

All Implemented Interfaces:

org.apache.geode.cache.CacheCallback, org.apache.geode.cache.Declarable, org.apache.geode.cache.query.CqListener

public class CqListenerImpl
extends java.lang.Object
implements org.apache.geode.cache.query.CqListener

CqListener class, implements CqListener interface methods. Offers callback methods for the CqQuery.

Since:

GemFire 5.5

Constructor Summary

Constructors

Constructor and Description
CqListenerImpl()

Method Summary

Modifier and Type	Method and Description
void	close() CQ is being closed, do any cleanup here
void	onError(org.apache.geode.cache.query.CqEvent aCqEvent) An error occurred in the processing of a CQ.
void	onEvent(org.apache.geode.cache.query.CqEvent aCqEvent) An event occurred that modifies the results of the query.

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

init

Constructor Detail

CqListenerImpl

public CqListenerImpl()

Method Detail

onEvent

public void onEvent(org.apache.geode.cache.query.CqEvent aCqEvent)

An event occurred that modifies the results of the query. This event does not contain an error.

Specified by:

onEvent in interface org.apache.geode.cache.query.CqListener

onError

public void onError(org.apache.geode.cache.query.CqEvent aCqEvent)

An error occurred in the processing of a CQ. This event does contain an error. The newValue and oldValue in the may or may not be available, and will be null if not available.

Specified by:

onError in interface org.apache.geode.cache.query.CqListener

close

public void close()

CQ is being closed, do any cleanup here

Specified by:

close in interface org.apache.geode.cache.CacheCallback