Class HazelcastContinuousQueryMessageProducer
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer
org.springframework.integration.hazelcast.inbound.HazelcastContinuousQueryMessageProducer
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.core.MessageProducer,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.ManageableSmartLifecycle,org.springframework.integration.support.management.TrackableComponent
Hazelcast Continuous Query Message Producer is a message producer which enables
AbstractHazelcastMessageProducer.HazelcastEntryListener with a
SqlPredicate in order to listen related distributed map events in the light of
defined predicate and sends events to related channel.- Since:
- 6.0
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer
AbstractHazelcastMessageProducer.AbstractHazelcastEventListener<E>, AbstractHazelcastMessageProducer.HazelcastEntryListener<K,V> -
Field Summary
Fields inherited from class org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer
distributedObjectFields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLockFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionHazelcastContinuousQueryMessageProducer(com.hazelcast.map.IMap distributedMap, String predicate) -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoStart()protected voiddoStop()voidsetIncludeValue(boolean includeValue) Methods inherited from class org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer
getCacheEvents, getCacheListeningPolicy, getHazelcastRegisteredEventListenerId, setCacheEventTypes, setCacheListeningPolicy, setHazelcastRegisteredEventListenerIdMethods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
HazelcastContinuousQueryMessageProducer
public HazelcastContinuousQueryMessageProducer(com.hazelcast.map.IMap distributedMap, String predicate)
-
-
Method Details
-
setIncludeValue
public void setIncludeValue(boolean includeValue) -
doStart
protected void doStart()- Overrides:
doStartin classorg.springframework.integration.endpoint.MessageProducerSupport
-
doStop
protected void doStop()- Overrides:
doStopin classorg.springframework.integration.endpoint.MessageProducerSupport
-
getComponentType
- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.context.IntegrationObjectSupport
-