public class ReactiveMessageSourceProducer extends MessageProducerSupport
MessageProducerSupport
to adapt a provided MessageSource
into a Flux
and let it be subscribed in the MessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>)
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
DEFAULT_PHASE
Constructor and Description |
---|
ReactiveMessageSourceProducer(MessageSource<?> messageSource)
Create an instance based on the provided
MessageSource . |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart()
Take no action by default.
|
void |
setDelayWhenEmpty(java.time.Duration delayWhenEmpty)
Configure a
Duration to delay next pull request when the previous one
was empty. |
afterSingletonsInstantiated, buildErrorMessage, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, 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, getComponentType, 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, getComponentType
public ReactiveMessageSourceProducer(MessageSource<?> messageSource)
MessageSource
.messageSource
- the MessageSource
to pull for messages.public void setDelayWhenEmpty(java.time.Duration delayWhenEmpty)
Duration
to delay next pull request when the previous one
was empty. Defaults to IntegrationReactiveUtils.DEFAULT_DELAY_WHEN_EMPTY
.delayWhenEmpty
- the Duration
to use.protected void doStart()
MessageProducerSupport
doStart
in class MessageProducerSupport