public abstract class AbstractReplyProducingMessageHandler extends AbstractMessageHandler implements MessageProducer, org.springframework.beans.factory.BeanClassLoaderAware
Modifier and Type | Class and Description |
---|---|
static interface |
AbstractReplyProducingMessageHandler.RequestHandler |
logger
Constructor and Description |
---|
AbstractReplyProducingMessageHandler() |
Modifier and Type | Method and Description |
---|---|
protected void |
doInit() |
protected java.lang.Object |
doInvokeAdvisedRequestHandler(Message<?> message) |
protected MessagingTemplate |
getMessagingTemplate()
Provides access to the
MessagingTemplate for subclasses. |
protected void |
handleMessageInternal(Message<?> message) |
protected abstract java.lang.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.
|
void |
setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain) |
void |
setBeanClassLoader(java.lang.ClassLoader beanClassLoader) |
void |
setChannelResolver(ChannelResolver channelResolver)
Set the ChannelResolver to be used when there is no default output channel.
|
void |
setOutputChannel(MessageChannel outputChannel)
Specify the MessageChannel to which produced Messages should be sent.
|
void |
setRequiresReply(boolean requiresReply)
Flag whether a reply is required.
|
void |
setSendTimeout(long sendTimeout)
Set the timeout for sending reply Messages.
|
protected boolean |
shouldCopyRequestHeaders()
Subclasses may override this.
|
getComponentType, getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public AbstractReplyProducingMessageHandler()
public void setOutputChannel(MessageChannel outputChannel)
MessageProducer
setOutputChannel
in interface MessageProducer
public void setSendTimeout(long sendTimeout)
public void setChannelResolver(ChannelResolver channelResolver)
public void setRequiresReply(boolean requiresReply)
protected MessagingTemplate getMessagingTemplate()
MessagingTemplate
for subclasses.public void setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain)
protected boolean hasAdviceChain()
public void setBeanClassLoader(java.lang.ClassLoader beanClassLoader)
setBeanClassLoader
in interface org.springframework.beans.factory.BeanClassLoaderAware
protected final void onInit()
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
protected void doInit()
protected final void handleMessageInternal(Message<?> message)
handleMessageInternal
in class AbstractMessageHandler
protected java.lang.Object doInvokeAdvisedRequestHandler(Message<?> message)
protected boolean shouldCopyRequestHeaders()
protected abstract java.lang.Object handleRequestMessage(Message<?> requestMessage)