public class BlockingProcessorExecutor extends Object implements ProcessorExecutor
ProcessorExecutor implementation executes each MessageProcessor
in sucession in the same thread until or processors have been invoked or one of the following is returned by a processor:
VoidMuleEventnull| Modifier and Type | Field and Description |
|---|---|
protected boolean |
copyOnVoidEvent |
protected MuleEvent |
event |
protected MessageProcessorExecutionTemplate |
messageProcessorExecutionTemplate |
protected List<MessageProcessor> |
processors |
| Constructor and Description |
|---|
BlockingProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate messageProcessorExecutionTemplate,
boolean copyOnVoidEvent) |
| Modifier and Type | Method and Description |
|---|---|
MuleEvent |
execute()
Executes a list of
MessageProcessors. |
protected MuleEvent |
executeNext() |
protected boolean |
hasNext() |
protected boolean |
isUseEventCopy(MuleEvent result) |
protected MessageProcessor |
nextProcessor() |
protected void |
preProcess(MessageProcessor processor) |
protected final MessageProcessorExecutionTemplate messageProcessorExecutionTemplate
protected final boolean copyOnVoidEvent
protected final List<MessageProcessor> processors
protected MuleEvent event
public BlockingProcessorExecutor(MuleEvent event, List<MessageProcessor> processors, MessageProcessorExecutionTemplate messageProcessorExecutionTemplate, boolean copyOnVoidEvent)
public final MuleEvent execute() throws MessagingException
ProcessorExecutorMessageProcessors.
Execution may or may not return the result of executing all of the MessageProcessor's
or not depending on the implementation. For example processing may be cut short in certain circumstance or be
continued in another thread at a later point in time.execute in interface ProcessorExecutorMessageProcessor's synchronously.MessagingException - exception thrown doing execution, if any.protected boolean hasNext()
protected MuleEvent executeNext() throws MessagingException
MessagingExceptionprotected boolean isUseEventCopy(MuleEvent result)
protected void preProcess(MessageProcessor processor)
protected MessageProcessor nextProcessor()
Copyright © 2003–2017 MuleSoft, Inc.. All rights reserved.