- All Implemented Interfaces:
- org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, org.springframework.integration.context.Orderable, org.springframework.integration.core.MessageProducer, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent, org.springframework.messaging.MessageHandler
public class FlowMessageHandler
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
A MessageHandler for Handling Flow input and output. Sends messages on its
input channel to the flow input channel and replies with the flow output (if
there is one) to its output channel.
Internally creates a subscriber to a PublishSubscribeChannel automatically
created for the flow. Since all FlowMessageHandler instances subscribe to
this channel, a unique flow conversationId is used to correlate flow input
and output messages
The output message contains a FLOW_OUTPUT_PORT_HEADER identifying which flow
output port produced the message
- See Also:
Error handling is done in a standard way. If the flow includes an error
channel which is bound to an output port, the handler will send the
ErrorMessage to the outputChannel. If the flow throws an exception, the
handler will create an ErrorMessage and send it to the outputChannel