org.springframework.integration.router
Class SplitterMessageHandlerAdapter

java.lang.Object
  extended by org.springframework.integration.util.AbstractMethodInvokingAdapter
      extended by org.springframework.integration.handler.AbstractMessageHandlerAdapter
          extended by org.springframework.integration.router.SplitterMessageHandlerAdapter
All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered, ChannelRegistryAware, MessageHandler, MethodInvoker

public class SplitterMessageHandlerAdapter
extends AbstractMessageHandlerAdapter
implements ChannelRegistryAware

MessageHandler adapter for methods annotated with @Splitter.

Author:
Mark Fisher, Marius Bogoevici

Field Summary
private  java.lang.String outputChannelName
           
private  long sendTimeout
           
 
Fields inherited from class org.springframework.integration.handler.AbstractMessageHandlerAdapter
OUTPUT_CHANNEL_NAME_KEY
 
Fields inherited from class org.springframework.integration.util.AbstractMethodInvokingAdapter
logger
 
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
 
Constructor Summary
SplitterMessageHandlerAdapter()
           
SplitterMessageHandlerAdapter(java.lang.Object object, java.lang.reflect.Method method)
           
SplitterMessageHandlerAdapter(java.lang.Object object, java.lang.String methodName)
           
 
Method Summary
protected  Message<?> handleReturnValue(java.lang.Object returnValue, Message<?> originalMessage)
          Subclasses must implement this method to handle the return value.
private  void prepareMessage(Message<?> message, java.lang.Object correlationId, int sequenceNumber, int sequenceSize)
           
private  boolean sendMessage(Message<?> message, java.lang.String channelName)
           
 void setOutputChannelName(java.lang.String outputChannelName)
           
 void setSendTimeout(long sendTimeout)
           
 
Methods inherited from class org.springframework.integration.handler.AbstractMessageHandlerAdapter
createReplyMessage, getChannelRegistry, handle, setChannelRegistry, setMessageCreator, setMessageMapper, setMethodExpectsMessage
 
Methods inherited from class org.springframework.integration.util.AbstractMethodInvokingAdapter
afterPropertiesSet, getMethod, getMethodName, getObject, getOrder, initialize, invokeMethod, isInitialized, setMethod, setMethodName, setObject, setOrder
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.springframework.integration.channel.ChannelRegistryAware
setChannelRegistry
 

Field Detail

outputChannelName

private volatile java.lang.String outputChannelName

sendTimeout

private volatile long sendTimeout
Constructor Detail

SplitterMessageHandlerAdapter

public SplitterMessageHandlerAdapter(java.lang.Object object,
                                     java.lang.reflect.Method method)

SplitterMessageHandlerAdapter

public SplitterMessageHandlerAdapter(java.lang.Object object,
                                     java.lang.String methodName)

SplitterMessageHandlerAdapter

public SplitterMessageHandlerAdapter()
Method Detail

setOutputChannelName

public void setOutputChannelName(java.lang.String outputChannelName)

setSendTimeout

public void setSendTimeout(long sendTimeout)

handleReturnValue

protected final Message<?> handleReturnValue(java.lang.Object returnValue,
                                             Message<?> originalMessage)
Description copied from class: AbstractMessageHandlerAdapter
Subclasses must implement this method to handle the return value.

Specified by:
handleReturnValue in class AbstractMessageHandlerAdapter

prepareMessage

private void prepareMessage(Message<?> message,
                            java.lang.Object correlationId,
                            int sequenceNumber,
                            int sequenceSize)

sendMessage

private boolean sendMessage(Message<?> message,
                            java.lang.String channelName)