public class SynchronousDispatcherMessageHandler
extends org.springframework.integration.handler.AbstractMessageProducingHandler
MessageHandler
and delegates processing to a Reactor Stream with synchronous dispatch so that processing
occurs on the same thread that invokes the handler.
The output stream of the processor is consumed and sent to the output channel.| Modifier and Type | Field and Description |
|---|---|
protected org.apache.commons.logging.Log |
logger |
| Constructor and Description |
|---|
SynchronousDispatcherMessageHandler(Processor processor)
Construct a new SynchronousDispatcherMessageHandler given the reactor based Processor to delegate
processing to.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
getOutputChannel, onInit, produceOutput, sendOutputs, setChannelResolver, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutputgetComponentType, getOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic SynchronousDispatcherMessageHandler(Processor processor)
processor - The stream based reactor processor