Package org.springframework.data.gemfire.listener

Class ContinuousQueryListenerContainer.EventDispatcherAdapter

java.lang.Object

org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer.EventDispatcherAdapter

All Implemented Interfaces:

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

Enclosing class:

ContinuousQueryListenerContainer

protected class ContinuousQueryListenerContainer.EventDispatcherAdapter
extends Object
implements org.apache.geode.cache.query.CqListener

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EventDispatcherAdapter(ContinuousQueryListener listener)

Method Summary

Modifier and Type	Method	Description
void	close()
protected ContinuousQueryListener	getListener()
void	onError(org.apache.geode.cache.query.CqEvent event)
void	onEvent(org.apache.geode.cache.query.CqEvent event)

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, initialize

Constructor Details

EventDispatcherAdapter

protected EventDispatcherAdapter(ContinuousQueryListener listener)

Method Details

getListener

protected ContinuousQueryListener getListener()

onError

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

Specified by:

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

onEvent

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

Specified by:

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

close

public void close()

Specified by:

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