public class DynamicPipelineMessageProcessor extends AbstractInterceptingMessageProcessor implements DynamicPipeline
logger, muleContext, next, notificationHandler
PROPERTY_NAME
Constructor and Description |
---|
DynamicPipelineMessageProcessor(Flow flow) |
Modifier and Type | Method and Description |
---|---|
DynamicPipelineBuilder |
dynamicPipeline(String id)
Provide access to a
DynamicPipelineBuilder that allows modifying
the dynamic pipeline injecting message processors and resetting the pipeline |
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
void |
setListener(MessageProcessor next)
Set the MessageProcessor listener on a message source which will be invoked
when a message is received or generated.
|
addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setMuleContext, toString
public DynamicPipelineMessageProcessor(Flow flow)
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
public void setListener(MessageProcessor next)
MessageSource
setListener
in interface MessageSource
setListener
in class AbstractInterceptingMessageProcessorBase
public DynamicPipelineBuilder dynamicPipeline(String id) throws DynamicPipelineException
DynamicPipeline
DynamicPipelineBuilder
that allows modifying
the dynamic pipeline injecting message processors and resetting the pipelinedynamicPipeline
in interface DynamicPipeline
id
- dynamic pipeline IDDynamicPipelineException
- if the pipeline ID is not validCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.