org.springframework.integration.router
Class SplitterMessageHandlerAdapter

java.lang.Object
  org.springframework.integration.handler.AbstractMessageHandlerAdapter
      org.springframework.integration.router.SplitterMessageHandlerAdapter

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, ChannelRegistryAware, MessageHandler

public class SplitterMessageHandlerAdapter
extends AbstractMessageHandlerAdapter
implements ChannelRegistryAware

MessageHandler adapter for methods annotated with @Splitter.

Author:

Mark Fisher, Marius Bogoevici

Field Summary

private ChannelRegistry	channelRegistry
private java.lang.String	outputChannelName
private long	sendTimeout

Fields inherited from class org.springframework.integration.handler.AbstractMessageHandlerAdapter

invoker, logger, OUTPUT_CHANNEL_NAME_KEY

Constructor Summary

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

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

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	setChannelRegistry(ChannelRegistry channelRegistry)
void	setSendTimeout(long sendTimeout)

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandlerAdapter

afterPropertiesSet, createReplyMessage, getMethod, getObject, handle, initialize, setMessageCreator, setMessageMapper, setMethod, setMethodExpectsMessage, setMethodName, setObject

Methods inherited from class java.lang.Object

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

Field Detail

outputChannelName

private final java.lang.String outputChannelName

channelRegistry

private volatile ChannelRegistry channelRegistry

sendTimeout

private volatile long sendTimeout

Constructor Detail

SplitterMessageHandlerAdapter

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

SplitterMessageHandlerAdapter

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

Method Detail

setChannelRegistry

public void setChannelRegistry(ChannelRegistry channelRegistry)

Specified by:

setChannelRegistry in interface ChannelRegistryAware

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)