public abstract class AbstractReplyProducingMessageHandler extends AbstractMessageProducingHandler implements org.springframework.beans.factory.BeanClassLoaderAware
Modifier and Type | Class and Description |
---|---|
static interface |
AbstractReplyProducingMessageHandler.RequestHandler
An implementation of this interface is used to wrap the
handleRequestMessage(Message)
method. |
messagingTemplate
EXPRESSION_PARSER, logger
Constructor and Description |
---|
AbstractReplyProducingMessageHandler() |
Modifier and Type | Method and Description |
---|---|
protected void |
doInit() |
protected java.lang.Object |
doInvokeAdvisedRequestHandler(org.springframework.messaging.Message<?> message) |
protected boolean |
getRequiresReply() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected abstract java.lang.Object |
handleRequestMessage(org.springframework.messaging.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 |
setRequiresReply(boolean requiresReply)
Flag whether a reply is required.
|
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, 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.protected boolean getRequiresReply()
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() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class AbstractMessageProducingHandler
java.lang.Exception
- Any exception.protected void doInit()
protected final void handleMessageInternal(org.springframework.messaging.Message<?> message)
handleMessageInternal
in class AbstractMessageHandler
protected java.lang.Object doInvokeAdvisedRequestHandler(org.springframework.messaging.Message<?> message)
protected abstract java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
requestMessage
- The request message.null
.