org.springframework.integration.router
Class SplitterMessageHandlerAdapter
java.lang.Object
org.springframework.integration.util.AbstractMethodInvokingAdapter
org.springframework.integration.handler.AbstractMessageHandlerAdapter
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
Fields inherited from interface org.springframework.core.Ordered |
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE |
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 |
outputChannelName
private volatile java.lang.String outputChannelName
sendTimeout
private volatile long sendTimeout
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()
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)