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.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.

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

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

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