- All Implemented Interfaces:
- org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.data.gemfire.listener.ContinuousQueryListener, org.springframework.integration.core.MessageProducer, org.springframework.integration.expression.IntegrationEvaluationContextAware, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent
public class ContinuousQueryMessageProducer
extends org.springframework.integration.endpoint.ExpressionMessageProducerSupport
implements org.springframework.data.gemfire.listener.ContinuousQueryListener
Responds to a Gemfire continuous query (set using the #query field) that is
constantly evaluated against a cache
Region. This is much faster than
re-querying the cache manually.
- Since:
- 2.1