public class GatewayMessageHandler extends AbstractReplyProducingMessageHandler implements ManageableLifecycle
AbstractReplyProducingMessageHandler implementation for mid-flow Gateway.AbstractReplyProducingMessageHandler.RequestHandlerIntegrationManagement.ManagementOverridesmessagingTemplateEXPRESSION_PARSER, loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCEMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
GatewayMessageHandler() |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
boolean |
isRunning() |
void |
setErrorChannel(org.springframework.messaging.MessageChannel errorChannel) |
void |
setErrorChannelName(java.lang.String errorChannel) |
void |
setReplyChannel(org.springframework.messaging.MessageChannel replyChannel) |
void |
setReplyChannelName(java.lang.String replyChannel) |
void |
setReplyTimeout(java.lang.Long replyTimeout) |
void |
setRequestChannel(org.springframework.messaging.MessageChannel requestChannel) |
void |
setRequestChannelName(java.lang.String requestChannel) |
void |
setRequestTimeout(java.lang.Long requestTimeout) |
void |
start() |
void |
stop() |
doInit, doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadershandleMessage, onComplete, onError, onNext, onSubscribebuildSendTimer, destroy, getComponentType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetThisAsgetBeanName, getComponentNamepublic void setRequestChannel(org.springframework.messaging.MessageChannel requestChannel)
public void setRequestChannelName(java.lang.String requestChannel)
public void setReplyChannel(org.springframework.messaging.MessageChannel replyChannel)
public void setReplyChannelName(java.lang.String replyChannel)
public void setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)
public void setErrorChannelName(java.lang.String errorChannel)
public void setRequestTimeout(java.lang.Long requestTimeout)
public void setReplyTimeout(java.lang.Long replyTimeout)
protected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
AbstractReplyProducingMessageHandlerhandleRequestMessage in class AbstractReplyProducingMessageHandlerrequestMessage - The request message.null.public void start()
start in interface org.springframework.context.Lifecyclestart in interface ManageableLifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclestop in interface ManageableLifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.LifecycleisRunning in interface ManageableLifecycle