org.springframework.integration.router
Class RouterMessageHandlerAdapter
java.lang.Object
org.springframework.integration.handler.AbstractMessageHandlerAdapter
org.springframework.integration.router.RouterMessageHandlerAdapter
- All Implemented Interfaces:
- org.springframework.beans.factory.InitializingBean, ChannelRegistryAware, MessageHandler
public class RouterMessageHandlerAdapter
- extends AbstractMessageHandlerAdapter
- implements ChannelRegistryAware
MessageHandler adapter for methods annotated with @Router
.
- Author:
- Mark Fisher
Methods inherited from class org.springframework.integration.handler.AbstractMessageHandlerAdapter |
afterPropertiesSet, createReplyMessage, getMethod, getObject, handle, setMessageCreator, setMessageMapper, setMethod, setMethodExpectsMessage, setMethodName, setObject |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
channelRegistry
private volatile ChannelRegistry channelRegistry
RouterMessageHandlerAdapter
public RouterMessageHandlerAdapter(java.lang.Object object,
java.lang.reflect.Method method)
RouterMessageHandlerAdapter
public RouterMessageHandlerAdapter(java.lang.Object object,
java.lang.String methodName)
setChannelRegistry
public void setChannelRegistry(ChannelRegistry channelRegistry)
- Specified by:
setChannelRegistry
in interface ChannelRegistryAware
initialize
protected void initialize()
- Description copied from class:
AbstractMessageHandlerAdapter
- Subclasses may override this method for custom initialization requirements.
- Overrides:
initialize
in class AbstractMessageHandlerAdapter
handleReturnValue
protected 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
sendMessage
private boolean sendMessage(Message<?> message,
java.lang.String channelName)
sendMessage
private boolean sendMessage(Message<?> message,
MessageChannel channel)