org.mule.routing
Class MessageChunkSplitter

java.lang.Object
  extended by org.mule.processor.AbstractInterceptingMessageProcessorBase
      extended by org.mule.processor.AbstractInterceptingMessageProcessor
          extended by org.mule.routing.outbound.AbstractMessageSequenceSplitter
              extended by org.mule.routing.AbstractSplitter
                  extended by org.mule.routing.MessageChunkSplitter
All Implemented Interfaces:
AnnotatedObject, MuleContextAware, InterceptingMessageProcessor, MessageProcessor, MessageProcessorContainer, MessageSource

public class MessageChunkSplitter
extends AbstractSplitter

A router that breaks up the current message onto smaller parts and sends them to the same destination. The Destination service needs to have a MessageChunkingAggregator inbound router in order to rebuild the message at the other end.

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


Field Summary
protected  int messageSize
           
 
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.AnnotatedObject
PROPERTY_NAME
 
Constructor Summary
MessageChunkSplitter()
           
 
Method Summary
 int getMessageSize()
           
protected  boolean isSplitRequired(MuleEvent event)
           
 void setMessageSize(int messageSize)
           
protected  List<MuleMessage> splitMessage(MuleEvent event)
           
 
Methods inherited from class org.mule.routing.AbstractSplitter
splitMessageIntoSequence
 
Methods inherited from class org.mule.routing.outbound.AbstractMessageSequenceSplitter
process, processParts, setBatchSize, setCounterVariableName, setEnableCorrelation, setMessageInfoMapping, setMuleContext
 
Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase
addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, toString
 
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

messageSize

protected int messageSize
Constructor Detail

MessageChunkSplitter

public MessageChunkSplitter()
Method Detail

getMessageSize

public int getMessageSize()

setMessageSize

public void setMessageSize(int messageSize)

isSplitRequired

protected boolean isSplitRequired(MuleEvent event)
Overrides:
isSplitRequired in class AbstractMessageSequenceSplitter

splitMessage

protected List<MuleMessage> splitMessage(MuleEvent event)
                                  throws RoutingException
Specified by:
splitMessage in class AbstractSplitter
Throws:
RoutingException


Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.