public class CacheListeningMessageProducer extends ExpressionMessageProducerSupport
EventType
enum for all options. A SpEL expression may be provided to generate a Message payload by
evaluating that expression against the EntryEvent
instance as the root object. If no
payloadExpression is provided, the EntryEvent
itself will be the payload.lifecycleCondition, lifecycleLock
EXPRESSION_PARSER
DEFAULT_PHASE
Constructor and Description |
---|
CacheListeningMessageProducer(org.apache.geode.cache.Region<?,?> region) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart()
Take no action by default.
|
protected void |
doStop()
Take no action by default.
|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
void |
setSupportedEventTypes(EventType... eventTypes) |
evaluatePayloadExpression, onInit, setIntegrationEvaluationContext, setPayloadExpression, setPayloadExpressionString
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
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, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getBeanName, getComponentName
public CacheListeningMessageProducer(org.apache.geode.cache.Region<?,?> region)
public void setSupportedEventTypes(EventType... eventTypes)
public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
protected void doStart()
MessageProducerSupport
doStart
in class MessageProducerSupport
protected void doStop()
MessageProducerSupport
doStop
in class MessageProducerSupport