Class WebFlux
java.lang.Object
org.springframework.integration.webflux.dsl.WebFlux
The WebFlux components Factory.
- Since:
- 5.0
-
Method Summary
Modifier and TypeMethodDescriptionstatic WebFluxInboundEndpointSpecinboundChannelAdapter(String... path) Create anWebFluxInboundEndpointSpecbuilder for one-way reactive adapter based on the providedpatharray for mapping.static WebFluxInboundEndpointSpecinboundGateway(String... path) Create anWebFluxInboundEndpointSpecbuilder for request-reply reactive gateway based on the providedpatharray for mapping.static WebFluxMessageHandlerSpecCreate anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provideduri.static WebFluxMessageHandlerSpecoutboundChannelAdapter(String uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provideduriandWebClient.static WebFluxMessageHandlerSpecCreate anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedURI.static WebFluxMessageHandlerSpecoutboundChannelAdapter(URI uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedURIandWebClient.static <P> WebFluxMessageHandlerSpecoutboundChannelAdapter(Function<org.springframework.messaging.Message<P>, ?> uriFunction) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedFunctionto evaluate targeturiagainst request message.static <P> WebFluxMessageHandlerSpecoutboundChannelAdapter(Function<org.springframework.messaging.Message<P>, ?> uriFunction, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedFunctionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.static WebFluxMessageHandlerSpecoutboundChannelAdapter(org.springframework.expression.Expression uriExpression) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provided SpELExpressionto evaluate targeturiagainst request message.static WebFluxMessageHandlerSpecoutboundChannelAdapter(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provided SpELExpressionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.static WebFluxMessageHandlerSpecoutboundGateway(String uri) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provideduri.static WebFluxMessageHandlerSpecoutboundGateway(String uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provideduriandWebClient.static WebFluxMessageHandlerSpecoutboundGateway(URI uri) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedURI.static WebFluxMessageHandlerSpecoutboundGateway(URI uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedURIandWebClient.static <P> WebFluxMessageHandlerSpecoutboundGateway(Function<org.springframework.messaging.Message<P>, ?> uriFunction) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedFunctionto evaluate targeturiagainst request message.static <P> WebFluxMessageHandlerSpecoutboundGateway(Function<org.springframework.messaging.Message<P>, ?> uriFunction, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedFunctionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.static WebFluxMessageHandlerSpecoutboundGateway(org.springframework.expression.Expression uriExpression) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provided SpELExpressionto evaluate targeturiagainst request message.static WebFluxMessageHandlerSpecoutboundGateway(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provided SpELExpressionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.
-
Method Details
-
outboundChannelAdapter
Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedURI.- Parameters:
uri- theURIto send requests.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provideduri.- Parameters:
uri- theurito send requests.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
public static <P> WebFluxMessageHandlerSpec outboundChannelAdapter(Function<org.springframework.messaging.Message<P>, ?> uriFunction) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedFunctionto evaluate targeturiagainst request message.- Type Parameters:
P- the expected payload type.- Parameters:
uriFunction- theFunctionto evaluateuriat runtime.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
public static WebFluxMessageHandlerSpec outboundChannelAdapter(org.springframework.expression.Expression uriExpression) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provided SpELExpressionto evaluate targeturiagainst request message.- Parameters:
uriExpression- the SpELExpressionto evaluateuriat runtime.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
public static WebFluxMessageHandlerSpec outboundChannelAdapter(URI uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedURIandWebClient.- Parameters:
uri- theURIto send requests.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
public static WebFluxMessageHandlerSpec outboundChannelAdapter(String uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provideduriandWebClient.- Parameters:
uri- theurito send requests.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
public static <P> WebFluxMessageHandlerSpec outboundChannelAdapter(Function<org.springframework.messaging.Message<P>, ?> uriFunction, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedFunctionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.- Type Parameters:
P- the expected payload type.- Parameters:
uriFunction- theFunctionto evaluateuriat runtime.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundChannelAdapter
public static WebFluxMessageHandlerSpec outboundChannelAdapter(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provided SpELExpressionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.- Parameters:
uriExpression- the SpELExpressionto evaluateuriat runtime.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedURI.- Parameters:
uri- theURIto send requests.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provideduri.- Parameters:
uri- theurito send requests.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
public static <P> WebFluxMessageHandlerSpec outboundGateway(Function<org.springframework.messaging.Message<P>, ?> uriFunction) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedFunctionto evaluate targeturiagainst request message.- Type Parameters:
P- the expected payload type.- Parameters:
uriFunction- theFunctionto evaluateuriat runtime.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
public static WebFluxMessageHandlerSpec outboundGateway(org.springframework.expression.Expression uriExpression) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provided SpELExpressionto evaluate targeturiagainst request message.- Parameters:
uriExpression- the SpELExpressionto evaluateuriat runtime.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
public static WebFluxMessageHandlerSpec outboundGateway(URI uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedURIandWebClient.- Parameters:
uri- theURIto send requests.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
public static WebFluxMessageHandlerSpec outboundGateway(String uri, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provideduriandWebClient.- Parameters:
uri- theurito send requests.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
public static <P> WebFluxMessageHandlerSpec outboundGateway(Function<org.springframework.messaging.Message<P>, ?> uriFunction, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedFunctionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.- Type Parameters:
P- the expected payload type.- Parameters:
uriFunction- theFunctionto evaluateuriat runtime.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
outboundGateway
public static WebFluxMessageHandlerSpec outboundGateway(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.WebClient webClient) Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provided SpELExpressionto evaluate targeturiagainst request message andWebClientfor HTTP exchanges.- Parameters:
uriExpression- the SpELExpressionto evaluateuriat runtime.webClient-WebClientto use.- Returns:
- the WebFluxMessageHandlerSpec instance
-
inboundChannelAdapter
Create anWebFluxInboundEndpointSpecbuilder for one-way reactive adapter based on the providedpatharray for mapping.- Parameters:
path- the path mapping URIs (e.g. "/myPath.do").- Returns:
- the WebFluxInboundEndpointSpec instance
-
inboundGateway
Create anWebFluxInboundEndpointSpecbuilder for request-reply reactive gateway based on the providedpatharray for mapping.- Parameters:
path- the path mapping URIs (e.g. "/myPath.do").- Returns:
- the WebFluxInboundEndpointSpec instance
-