public class ContinuousQueryMessageProducer extends ExpressionMessageProducerSupport implements org.springframework.data.gemfire.listener.ContinuousQueryListener
Region. This is much faster than
re-querying the cache manually.| Constructor and Description |
|---|
ContinuousQueryMessageProducer(org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer queryListenerContainer,
java.lang.String query) |
| Modifier and Type | Method and Description |
|---|---|
void |
onEvent(com.gemstone.gemfire.cache.query.CqEvent event) |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setDurable(boolean durable) |
void |
setQueryName(java.lang.String queryName) |
void |
setSupportedEventTypes(CqEventType... eventTypes) |
evaluatePayloadExpression, setIntegrationEvaluationContext, setPayloadExpressiondoStart, doStop, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackgetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentName, getComponentTypepublic ContinuousQueryMessageProducer(org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer queryListenerContainer,
java.lang.String query)
queryListenerContainer - a ContinuousQueryListenerContainerquery - the query stringpublic void setQueryName(java.lang.String queryName)
queryName - optional query namepublic void setDurable(boolean durable)
durable - true if the query is a durable subscriptionpublic void setSupportedEventTypes(CqEventType... eventTypes)
protected void onInit()
IntegrationObjectSupportonInit in class ExpressionMessageProducerSupportpublic void onEvent(com.gemstone.gemfire.cache.query.CqEvent event)
onEvent in interface org.springframework.data.gemfire.listener.ContinuousQueryListener