public class WebFluxMessageHandlerSpec extends BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>
BaseHttpMessageHandlerSpec implementation for the WebFluxRequestExecutingMessageHandler.WebFluxRequestExecutingMessageHandlerlogger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
WebFluxMessageHandlerSpec |
bodyExtractor(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. |
protected WebFluxMessageHandlerSpec |
expectReply(boolean expectReply) |
protected boolean |
isClientSet() |
WebFluxMessageHandlerSpec |
replyPayloadToFlux(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. |
charset, encodeUri, expectedResponseType, expectedResponseType, expectedResponseTypeExpression, expectedResponseTypeFunction, extractPayload, getComponentsToRegister, headerMapper, httpMethod, httpMethodExpression, httpMethodFunction, mappedRequestHeaders, mappedResponseHeaders, transferCookies, uriVariable, uriVariable, uriVariable, uriVariableExpressions, uriVariablesExpression, uriVariablesExpression, uriVariablesFunction_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, idpublic WebFluxMessageHandlerSpec replyPayloadToFlux(boolean replyPayloadToFlux)
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.replyPayloadToFlux - represent reply payload as a
Flux or as a value from the
Mono.WebFluxRequestExecutingMessageHandler.setReplyPayloadToFlux(boolean)public WebFluxMessageHandlerSpec bodyExtractor(org.springframework.web.reactive.function.BodyExtractor<?,org.springframework.http.client.reactive.ClientHttpResponse> bodyExtractor)
BodyExtractor as an alternative to the expectedResponseType
to allow to get low-level access to the received ClientHttpResponse.bodyExtractor - the BodyExtractor to use.WebFluxRequestExecutingMessageHandler.setBodyExtractor(BodyExtractor)protected boolean isClientSet()
isClientSet in class BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>protected WebFluxMessageHandlerSpec expectReply(boolean expectReply)