public class ContinuousQueryMessageProducer
extends org.springframework.integration.endpoint.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 |
---|---|
java.lang.String |
getComponentType() |
void |
onEvent(com.gemstone.gemfire.cache.query.CqEvent event) |
protected void |
onInit() |
void |
setDurable(boolean durable) |
void |
setQueryName(java.lang.String queryName) |
void |
setSupportedEventTypes(CqEventType... eventTypes) |
evaluatePayloadExpression, setIntegrationEvaluationContext, setPayloadExpression
doStart, doStop, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toString
public ContinuousQueryMessageProducer(org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer queryListenerContainer, java.lang.String query)
queryListenerContainer
- a ContinuousQueryListenerContainer
query
- 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)
public java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport
protected void onInit()
onInit
in class org.springframework.integration.endpoint.ExpressionMessageProducerSupport
public void onEvent(com.gemstone.gemfire.cache.query.CqEvent event)
onEvent
in interface org.springframework.data.gemfire.listener.ContinuousQueryListener