Package org.springframework.integration.http.outbound

Class HttpRequestExecutingMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.MessageHandlerSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.integration.handler.AbstractReplyProducingMessageHandler

org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler

org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler

All Implemented Interfaces:

org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

public class HttpRequestExecutingMessageHandler
extends AbstractHttpRequestExecutingMessageHandler

A MessageHandler implementation that executes HTTP requests by delegating to a RestTemplate instance. If the 'expectReply' flag is set to true (the default) then a reply Message will be generated from the HTTP response. If that response contains a body, it will be used as the reply Message's payload. Otherwise the reply Message's payload will contain the response status as an instance of the HttpStatus enum. When there is a response body, the HttpStatus enum instance will instead be copied to the MessageHeaders of the reply. In both cases, the response headers will be mapped to the reply Message's headers by this handler's HeaderMapper instance.

Since:

2.0

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell, Gunnar Hillert, Artem Bilan, Wallace Wadge, Shiliang Li

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

AbstractReplyProducingMessageHandler.RequestHandler

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler

uriFactory

Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

messagingTemplate

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
HttpRequestExecutingMessageHandler(String uri)	Create a handler that will send requests to the provided URI.
HttpRequestExecutingMessageHandler(String uri, RestTemplate restTemplate)	Create a handler that will send requests to the provided URI using a provided RestTemplate.
HttpRequestExecutingMessageHandler(URI uri)	Create a handler that will send requests to the provided URI.
HttpRequestExecutingMessageHandler(Expression uriExpression)	Create a handler that will send requests to the provided URI Expression.
HttpRequestExecutingMessageHandler(Expression uriExpression, RestTemplate restTemplate)	4 Create a handler that will send requests to the provided URI using a provided RestTemplate.

Method Summary

Modifier and Type	Method	Description
protected Object	exchange(Object uri, HttpMethod httpMethod, HttpEntity<?> httpRequest, Object expectedResponseType, Message<?> requestMessage, Map<String,?> uriVariables)
String	getComponentType()	Subclasses may implement this method to provide component type information.
void	setEncodingMode(DefaultUriBuilderFactory.EncodingMode encodingMode)	Set the encoding mode to use.
void	setErrorHandler(ResponseErrorHandler errorHandler)	Set the ResponseErrorHandler for the underlying RestTemplate.
void	setMessageConverters(List<HttpMessageConverter<?>> messageConverters)	Set a list of HttpMessageConverters to be used by the underlying RestTemplate.
void	setRequestFactory(ClientHttpRequestFactory requestFactory)	Set the ClientHttpRequestFactory for the underlying RestTemplate.

Methods inherited from class org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler

doInit, evaluateTypeFromExpression, getIntegrationPatternType, getReply, handleRequestMessage, isExpectReply, mapHeaders, setCharset, setExpectedResponseType, setExpectedResponseTypeExpression, setExpectReply, setExtractPayload, setExtractResponseBody, setHeaderMapper, setHttpMethod, setHttpMethodExpression, setTransferCookies, setTrustedSpel, setUriVariableExpressions, setUriVariablesExpression

Methods inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply

Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, 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, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Details

HttpRequestExecutingMessageHandler

public HttpRequestExecutingMessageHandler(URI uri)

Create a handler that will send requests to the provided URI.

Parameters:

uri - The URI.

HttpRequestExecutingMessageHandler

public HttpRequestExecutingMessageHandler(String uri)

Create a handler that will send requests to the provided URI.

Parameters:

uri - The URI.

HttpRequestExecutingMessageHandler

public HttpRequestExecutingMessageHandler(Expression uriExpression)

Create a handler that will send requests to the provided URI Expression.

Parameters:

uriExpression - The URI expression.

HttpRequestExecutingMessageHandler

public HttpRequestExecutingMessageHandler(String uri,
 RestTemplate restTemplate)

Create a handler that will send requests to the provided URI using a provided RestTemplate.

Parameters:

uri - The URI.

restTemplate - The rest template.

HttpRequestExecutingMessageHandler

public HttpRequestExecutingMessageHandler(Expression uriExpression,
 @Nullable
 RestTemplate restTemplate)

4 Create a handler that will send requests to the provided URI using a provided RestTemplate.

Parameters:

uriExpression - A SpEL Expression that can be resolved against the message object and BeanFactory.

restTemplate - The rest template.

Method Details

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class MessageHandlerSupport

setErrorHandler

public void setErrorHandler(ResponseErrorHandler errorHandler)

Set the ResponseErrorHandler for the underlying RestTemplate.

Parameters:

errorHandler - The error handler.

See Also:

• RestTemplate.setErrorHandler(ResponseErrorHandler)

setMessageConverters

public void setMessageConverters(List<HttpMessageConverter<?>> messageConverters)

Set a list of HttpMessageConverters to be used by the underlying RestTemplate. Converters configured via this method will override the default converters.

Parameters:

messageConverters - The message converters.

See Also:

• RestTemplate.setMessageConverters(java.util.List)

setRequestFactory

public void setRequestFactory(ClientHttpRequestFactory requestFactory)

Set the ClientHttpRequestFactory for the underlying RestTemplate.

Parameters:

requestFactory - The request factory.

See Also:

• InterceptingHttpAccessor.setRequestFactory(ClientHttpRequestFactory)

setEncodingMode

public void setEncodingMode(DefaultUriBuilderFactory.EncodingMode encodingMode)

Description copied from class: AbstractHttpRequestExecutingMessageHandler

Set the encoding mode to use. By default, this is set to DefaultUriBuilderFactory.EncodingMode.TEMPLATE_AND_VALUES. For more complicated scenarios consider configuring an UriTemplateHandler on an externally provided RestTemplate.

Overrides:

setEncodingMode in class AbstractHttpRequestExecutingMessageHandler

Parameters:

encodingMode - the mode to use for uri encoding

exchange

@Nullable
protected Object exchange(Object uri,
 HttpMethod httpMethod,
 HttpEntity<?> httpRequest,
 Object expectedResponseType,
 Message<?> requestMessage,
 Map<String,?> uriVariables)

Specified by:

exchange in class AbstractHttpRequestExecutingMessageHandler