Class WebFluxMessageHandlerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<S,E>
org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>
org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<WebFluxRequestExecutingMessageHandler>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.dsl.ComponentsRegistration
public class WebFluxMessageHandlerSpec extends org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>
The
BaseHttpMessageHandlerSpec implementation for the WebFluxRequestExecutingMessageHandler.- Since:
- 5.0
- See Also:
WebFluxRequestExecutingMessageHandler
-
Field Summary
Fields Modifier and Type Field Description protected org.springframework.web.reactive.function.client.WebClientwebClient -
Constructor Summary
Constructors Modifier Constructor Description protectedWebFluxMessageHandlerSpec(java.lang.String uri, org.springframework.web.reactive.function.client.WebClient webClient)protectedWebFluxMessageHandlerSpec(java.net.URI uri, org.springframework.web.reactive.function.client.WebClient webClient)protectedWebFluxMessageHandlerSpec(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient) -
Method Summary
Modifier and Type Method Description WebFluxMessageHandlerSpecbodyExtractor(org.springframework.web.reactive.function.BodyExtractor<?,org.springframework.http.client.reactive.ClientHttpResponse> bodyExtractor)Specify aBodyExtractoras an alternative to theexpectedResponseTypeto allow to get low-level access to the receivedClientHttpResponse.protected WebFluxMessageHandlerSpecexpectReply(boolean expectReply)protected booleanisClientSet()WebFluxMessageHandlerSpecpublisherElementType(java.lang.Class<?> publisherElementType)Configure a type for a requestPublisherelements.WebFluxMessageHandlerSpecpublisherElementType(org.springframework.core.ParameterizedTypeReference<?> publisherElementType)Configure aParameterizedTypeReferencefor a requestPublisherelements.WebFluxMessageHandlerSpecpublisherElementTypeExpression(org.springframework.expression.Expression publisherElementTypeExpression)Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.<P> WebFluxMessageHandlerSpecpublisherElementTypeFunction(java.util.function.Function<org.springframework.messaging.Message<P>,?> typeFunction)Configure aFunctionto evaluate a requestPublisherelements type at runtime against a request message.WebFluxMessageHandlerSpecreplyPayloadToFlux(boolean replyPayloadToFlux)The boolean flag to identify if the reply payload should be as aFluxfrom the response body or as resolved value from theMonoof the response body.Methods inherited from class org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec
charset, encodeUri, encodingMode, expectedResponseType, expectedResponseType, expectedResponseTypeExpression, expectedResponseTypeFunction, extractPayload, getComponentsToRegister, headerMapper, httpMethod, httpMethodExpression, httpMethodFunction, mappedRequestHeaders, mappedResponseHeaders, transferCookies, uriVariable, uriVariable, uriVariable, uriVariableExpressions, uriVariablesExpression, uriVariablesExpression, uriVariablesFunctionMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
-
Field Details
-
webClient
protected final org.springframework.web.reactive.function.client.WebClient webClient
-
-
Constructor Details
-
WebFluxMessageHandlerSpec
protected WebFluxMessageHandlerSpec(java.net.URI uri, org.springframework.web.reactive.function.client.WebClient webClient) -
WebFluxMessageHandlerSpec
protected WebFluxMessageHandlerSpec(java.lang.String uri, org.springframework.web.reactive.function.client.WebClient webClient) -
WebFluxMessageHandlerSpec
protected WebFluxMessageHandlerSpec(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient)
-
-
Method Details
-
replyPayloadToFlux
The boolean flag to identify if the reply payload should be as aFluxfrom the response body or as resolved value from theMonoof the response body. Defaults tofalse- simple value is pushed downstream. Makes sense whenexpectedResponseTypeis configured.- Parameters:
replyPayloadToFlux- represent reply payload as aFluxor as a value from theMono.- Returns:
- the spec
- Since:
- 5.0.1
- See Also:
WebFluxRequestExecutingMessageHandler.setReplyPayloadToFlux(boolean)
-
bodyExtractor
public WebFluxMessageHandlerSpec bodyExtractor(org.springframework.web.reactive.function.BodyExtractor<?,org.springframework.http.client.reactive.ClientHttpResponse> bodyExtractor)Specify aBodyExtractoras an alternative to theexpectedResponseTypeto allow to get low-level access to the receivedClientHttpResponse.- Parameters:
bodyExtractor- theBodyExtractorto use.- Returns:
- the spec
- Since:
- 5.0.1
- See Also:
WebFluxRequestExecutingMessageHandler.setBodyExtractor(BodyExtractor)
-
publisherElementType
Configure a type for a requestPublisherelements.- Parameters:
publisherElementType- the type of the requestPublisherelements.- Returns:
- the spec
- Since:
- 5.2
- See Also:
WebFluxRequestExecutingMessageHandler.setPublisherElementType(java.lang.Class<?>)
-
publisherElementType
public WebFluxMessageHandlerSpec publisherElementType(org.springframework.core.ParameterizedTypeReference<?> publisherElementType)Configure aParameterizedTypeReferencefor a requestPublisherelements.- Parameters:
publisherElementType- the type of the requestPublisherelements.- Returns:
- the spec
- Since:
- 5.2
- See Also:
WebFluxRequestExecutingMessageHandler.setPublisherElementType(java.lang.Class<?>)
-
publisherElementTypeFunction
public <P> WebFluxMessageHandlerSpec publisherElementTypeFunction(java.util.function.Function<org.springframework.messaging.Message<P>,?> typeFunction)Configure aFunctionto evaluate a requestPublisherelements type at runtime against a request message.- Type Parameters:
P- the expected payload type.- Parameters:
typeFunction- theFunctionto evaluate a type for the requestPublisherelements.- Returns:
- the spec
- Since:
- 5.2
- See Also:
WebFluxRequestExecutingMessageHandler.setPublisherElementTypeExpression(Expression)
-
publisherElementTypeExpression
public WebFluxMessageHandlerSpec publisherElementTypeExpression(org.springframework.expression.Expression publisherElementTypeExpression)Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.- Parameters:
publisherElementTypeExpression- the expression to evaluate a type for the requestPublisherelements.- Returns:
- the spec
- Since:
- 5.2
- See Also:
WebFluxRequestExecutingMessageHandler.setPublisherElementTypeExpression(Expression)
-
isClientSet
protected boolean isClientSet()- Specified by:
isClientSetin classorg.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>
-
expectReply
- Overrides:
expectReplyin classorg.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>
-