org.springframework.integration.webflux.outbound

Class WebFluxRequestExecutingMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.integration.handler.AbstractReplyProducingMessageHandler

org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler

org.springframework.integration.webflux.outbound.WebFluxRequestExecutingMessageHandler

All Implemented Interfaces:

org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>

public class WebFluxRequestExecutingMessageHandler
extends AbstractHttpRequestExecutingMessageHandler

A MessageHandler implementation that executes HTTP requests by delegating to a Reactive WebClient instance.

Since:

5.0

Author:

Shiliang Li, Artem Bilan

See Also:

HttpRequestExecutingMessageHandler

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.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 and Description
WebFluxRequestExecutingMessageHandler(org.springframework.expression.Expression uriExpression) Create a handler that will send requests to the provided URI Expression.
WebFluxRequestExecutingMessageHandler(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient) Create a handler that will send requests to the provided URI using a provided WebClient.
WebFluxRequestExecutingMessageHandler(java.lang.String uri) Create a handler that will send requests to the provided URI.
WebFluxRequestExecutingMessageHandler(java.lang.String uri, org.springframework.web.reactive.function.client.WebClient webClient) Create a handler that will send requests to the provided URI using a provided WebClient.
WebFluxRequestExecutingMessageHandler(java.net.URI uri) Create a handler that will send requests to the provided URI.

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	exchange(java.util.function.Supplier<java.net.URI> uriSupplier, org.springframework.http.HttpMethod httpMethod, org.springframework.http.HttpEntity<?> httpRequest, java.lang.Object expectedResponseType, org.springframework.messaging.Message<?> requestMessage)
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
void	setBodyExtractor(org.springframework.web.reactive.function.BodyExtractor<?,org.springframework.http.client.reactive.ClientHttpResponse> bodyExtractor) Specify a BodyExtractor as an alternative to the expectedResponseType to allow to get low-level access to the received ClientHttpResponse.
void	setReplyPayloadToFlux(boolean replyPayloadToFlux) The boolean flag to identify if the reply payload should be as a Flux from the response body or as resolved value from the Mono of the response body.

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

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

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

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

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

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

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

configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, 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 org.springframework.integration.support.context.NamedComponent

getComponentName

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Constructor Detail

WebFluxRequestExecutingMessageHandler

public WebFluxRequestExecutingMessageHandler(java.net.URI uri)

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

Parameters:

uri - The URI.

WebFluxRequestExecutingMessageHandler

public WebFluxRequestExecutingMessageHandler(java.lang.String uri)

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

Parameters:

uri - The URI.

WebFluxRequestExecutingMessageHandler

public WebFluxRequestExecutingMessageHandler(org.springframework.expression.Expression uriExpression)

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

Parameters:

uriExpression - The URI expression.

WebFluxRequestExecutingMessageHandler

public WebFluxRequestExecutingMessageHandler(java.lang.String uri,
                                             org.springframework.web.reactive.function.client.WebClient webClient)

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

Parameters:

uri - The URI.

webClient - The WebClient to use.

WebFluxRequestExecutingMessageHandler

public WebFluxRequestExecutingMessageHandler(org.springframework.expression.Expression uriExpression,
                                             org.springframework.web.reactive.function.client.WebClient webClient)

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

Parameters:

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

webClient - The WebClient to use.

Method Detail

setReplyPayloadToFlux

public void setReplyPayloadToFlux(boolean replyPayloadToFlux)

The boolean flag to identify if the reply payload should be as a Flux from the response body or as resolved value from the Mono of the response body. Defaults to false - simple value is pushed downstream. Makes sense when expectedResponseType is configured.

Parameters:

replyPayloadToFlux - represent reply payload as a Flux or as a value from the Mono.

Since:

5.0.1

See Also:

AbstractHttpRequestExecutingMessageHandler.setExpectedResponseType(Class), AbstractHttpRequestExecutingMessageHandler.setExpectedResponseTypeExpression(Expression)

setBodyExtractor

public void setBodyExtractor(org.springframework.web.reactive.function.BodyExtractor<?,org.springframework.http.client.reactive.ClientHttpResponse> bodyExtractor)

Specify a BodyExtractor as an alternative to the expectedResponseType to allow to get low-level access to the received ClientHttpResponse.

Parameters:

bodyExtractor - the BodyExtractor to use.

Since:

5.0.1

See Also:

AbstractHttpRequestExecutingMessageHandler.setExpectedResponseType(Class), AbstractHttpRequestExecutingMessageHandler.setExpectedResponseTypeExpression(Expression)

getComponentType

public java.lang.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 AbstractMessageHandler

exchange

protected java.lang.Object exchange(java.util.function.Supplier<java.net.URI> uriSupplier,
                                    org.springframework.http.HttpMethod httpMethod,
                                    org.springframework.http.HttpEntity<?> httpRequest,
                                    java.lang.Object expectedResponseType,
                                    org.springframework.messaging.Message<?> requestMessage)

Specified by:

exchange in class AbstractHttpRequestExecutingMessageHandler