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

Class CqEventImpl

java.lang.Object

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

All Implemented Interfaces:

org.apache.geode.cache.query.CqEvent

public class CqEventImpl
extends java.lang.Object
implements org.apache.geode.cache.query.CqEvent

Method Summary

Modifier and Type	Method and Description
org.apache.geode.cache.Operation	getBaseOperation() Get the operation on the base region that triggered this event.
org.apache.geode.cache.query.CqQuery	getCq()
byte[]	getDeltaValue()
org.apache.geode.internal.cache.EventID	getEventID()
java.lang.Object	getKey() Get the key relating to the event.
java.lang.Object	getNewValue() Get the new value of the modification.
org.apache.geode.cache.Operation	getQueryOperation() Get the the operation on the query results.
org.apache.geode.cache.client.internal.QueueManager	getQueueManager()
java.lang.Throwable	getThrowable() If an error occurred, return the Throwable, otherwise return null.
void	setException() Checks if the Cq Event is for an exception.
void	setException(java.lang.String exceptionText)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getCq

public org.apache.geode.cache.query.CqQuery getCq()

Specified by:

getCq in interface org.apache.geode.cache.query.CqEvent

getBaseOperation

public org.apache.geode.cache.Operation getBaseOperation()

Get the operation on the base region that triggered this event.

Specified by:

getBaseOperation in interface org.apache.geode.cache.query.CqEvent

getQueryOperation

public org.apache.geode.cache.Operation getQueryOperation()

Get the the operation on the query results. Supported operations include update, create, and destroy.

Specified by:

getQueryOperation in interface org.apache.geode.cache.query.CqEvent

getKey

public java.lang.Object getKey()

Get the key relating to the event.

Specified by:

getKey in interface org.apache.geode.cache.query.CqEvent

Returns:

Object key.

getNewValue

public java.lang.Object getNewValue()

Get the new value of the modification. If there is no new value because this is a delete, then return null.

Specified by:

getNewValue in interface org.apache.geode.cache.query.CqEvent

getThrowable

public java.lang.Throwable getThrowable()

If an error occurred, return the Throwable, otherwise return null. If an error occurred, then this event will be passed to the onError method of the CqListener instead of the onEvent method.

Specified by:

getThrowable in interface org.apache.geode.cache.query.CqEvent

getDeltaValue

public byte[] getDeltaValue()

Specified by:

getDeltaValue in interface org.apache.geode.cache.query.CqEvent

setException

public void setException()

Checks if the Cq Event is for an exception. If so constructs the exception.

setException

public void setException(java.lang.String exceptionText)

getQueueManager

public org.apache.geode.cache.client.internal.QueueManager getQueueManager()

getEventID

public org.apache.geode.internal.cache.EventID getEventID()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object