public abstract class AbstractReplyProducingMessageHandler extends AbstractMessageProducingHandler implements BeanClassLoaderAware
Modifier and Type | Class and Description |
---|---|
static interface |
AbstractReplyProducingMessageHandler.RequestHandler |
messagingTemplate
logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
AbstractReplyProducingMessageHandler() |
Modifier and Type | Method and Description |
---|---|
protected void |
doInit() |
protected Object |
doInvokeAdvisedRequestHandler(Message<?> message) |
protected void |
handleMessageInternal(Message<?> message) |
protected abstract Object |
handleRequestMessage(Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
protected boolean |
hasAdviceChain() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
protected void |
produceReply(Object reply,
MessageHeaders requestHeaders) |
void |
setAdviceChain(List<org.aopalliance.aop.Advice> adviceChain) |
void |
setBeanClassLoader(ClassLoader beanClassLoader) |
void |
setChannelResolver(DestinationResolver<MessageChannel> channelResolver)
Set the DestinationResolver<MessageChannel> to be used when there is no default output channel.
|
void |
setRequiresReply(boolean requiresReply)
Flag whether a reply is required.
|
protected boolean |
shouldCopyRequestHeaders()
Subclasses may override this.
|
getOutputChannel, setOutputChannel, setOutputChannelName, setSendTimeout
getComponentType, getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public AbstractReplyProducingMessageHandler()
public void setRequiresReply(boolean requiresReply)
requiresReply
- true if a reply is required.public void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)
channelResolver
- The channel resolver.public void setAdviceChain(List<org.aopalliance.aop.Advice> adviceChain)
protected boolean hasAdviceChain()
public void setBeanClassLoader(ClassLoader beanClassLoader)
setBeanClassLoader
in interface BeanClassLoaderAware
protected final void onInit() throws Exception
IntegrationObjectSupport
onInit
in class AbstractMessageProducingHandler
Exception
- Any exception.protected void doInit()
protected final void handleMessageInternal(Message<?> message)
handleMessageInternal
in class AbstractMessageHandler
protected void produceReply(Object reply, MessageHeaders requestHeaders)
protected boolean shouldCopyRequestHeaders()
protected abstract Object handleRequestMessage(Message<?> requestMessage)
requestMessage
- The request message.null
.