org.mule.routing

Class ExpressionSplitter

java.lang.Object

org.mule.AbstractAnnotatedObject

org.mule.processor.AbstractInterceptingMessageProcessorBase

org.mule.processor.AbstractInterceptingMessageProcessor

org.mule.routing.outbound.AbstractMessageSequenceSplitter

org.mule.routing.AbstractSplitter

org.mule.routing.ExpressionSplitter

All Implemented Interfaces:

AnnotatedObject, MuleContextAware, Initialisable, InterceptingMessageProcessor, MessageProcessor, MessageProcessorContainer, MessageSource

public class ExpressionSplitter
extends AbstractSplitter
implements Initialisable

Splits a message using the expression provided invoking the next message processor one for each split part.

EIP Reference: http://www.eaipatterns.com/Sequencer.html

Field Summary

Fields

Modifier and Type	Field and Description
protected ExpressionConfig	config
protected ExpressionManager	expressionManager

Fields inherited from class org.mule.routing.outbound.AbstractMessageSequenceSplitter

batchSize, counterVariableName, enableCorrelation, messageInfoMapping, muleContext, resultsHandler

Fields inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

logger, next, notificationHandler

Fields inherited from interface org.mule.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.api.AnnotatedObject

PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
ExpressionSplitter()
ExpressionSplitter(ExpressionConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
String	getCustomEvaluator()
String	getEvaluator()
String	getExpression()
void	initialise() Method used to perform any initialisation work.
void	setCustomEvaluator(String customEvaluator)
void	setEvaluator(String evaluator)
void	setExpression(String expression)
protected List<MuleMessage>	splitMessage(MuleEvent event)

Methods inherited from class org.mule.routing.AbstractSplitter

splitMessageIntoSequence

Methods inherited from class org.mule.routing.outbound.AbstractMessageSequenceSplitter

isSplitRequired, process, processParts, setBatchSize, setCounterVariableName, setEnableCorrelation, setMessageInfoMapping, setMuleContext

Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, toString

Methods inherited from class org.mule.AbstractAnnotatedObject

getAnnotation, getAnnotations, setAnnotations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.mule.api.source.MessageSource

setListener

Field Detail

expressionManager

protected ExpressionManager expressionManager

config

protected ExpressionConfig config

Constructor Detail

ExpressionSplitter

public ExpressionSplitter()

ExpressionSplitter

public ExpressionSplitter(ExpressionConfig config)

Method Detail

initialise

public void initialise()
                throws InitialisationException

Description copied from interface: Initialisable

Method used to perform any initialisation work. If a fatal error occurs during initialisation an InitialisationException should be thrown, causing the Mule instance to shutdown. If the error is recoverable, say by retrying to connect, a RecoverableException should be thrown. There is no guarantee that by throwing a Recoverable exception that the Mule instance will not shut down.

Specified by:

initialise in interface Initialisable

Throws:

InitialisationException - if a fatal error occurs causing the Mule instance to shutdown

RecoverableException - if an error occurs that can be recovered from

splitMessage

protected List<MuleMessage> splitMessage(MuleEvent event)

Specified by:

splitMessage in class AbstractSplitter

getCustomEvaluator

public String getCustomEvaluator()

setCustomEvaluator

public void setCustomEvaluator(String customEvaluator)

getEvaluator

public String getEvaluator()

setEvaluator

public void setEvaluator(String evaluator)

getExpression

public String getExpression()

setExpression

public void setExpression(String expression)