public class WebFluxRequestExecutingMessageHandler extends AbstractHttpRequestExecutingMessageHandler
MessageHandler
implementation that executes HTTP requests by delegating
to a Reactive WebClient
instance.HttpRequestExecutingMessageHandler
AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
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.
|
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.
|
doInit, getReply, handleRequestMessage, isExpectReply, mapHeaders, setCharset, setEncodeUri, setExpectedResponseType, setExpectedResponseTypeExpression, setExpectReply, setExtractPayload, setHeaderMapper, setHttpMethod, setHttpMethodExpression, setTransferCookies, setUriVariableExpressions, setUriVariablesExpression
doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
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
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 WebFluxRequestExecutingMessageHandler(java.net.URI uri)
uri
- The URI.public WebFluxRequestExecutingMessageHandler(java.lang.String uri)
uri
- The URI.public WebFluxRequestExecutingMessageHandler(org.springframework.expression.Expression uriExpression)
uriExpression
- The URI expression.public WebFluxRequestExecutingMessageHandler(java.lang.String uri, org.springframework.web.reactive.function.client.WebClient webClient)
uri
- The URI.webClient
- The WebClient to use.public WebFluxRequestExecutingMessageHandler(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient)
uriExpression
- A SpEL Expression that can be resolved against the message object and
BeanFactory
.webClient
- The WebClient to use.public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
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)
exchange
in class AbstractHttpRequestExecutingMessageHandler