Class WebFlux
java.lang.Object
org.springframework.integration.webflux.dsl.WebFlux
public final class WebFlux
extends java.lang.Object
The WebFlux components Factory.
- Since:
- 5.0
-
Method Summary
Modifier and Type Method Description static WebFluxInboundEndpointSpecinboundChannelAdapter(java.lang.String... path)Create anWebFluxInboundEndpointSpecbuilder for one-way reactive adapter based on the providedpatharray for mapping.static WebFluxInboundEndpointSpecinboundGateway(java.lang.String... path)Create anWebFluxInboundEndpointSpecbuilder for request-reply reactive gateway based on the providedpatharray for mapping.static WebFluxMessageHandlerSpecoutboundChannelAdapter(java.lang.String uri)Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provideduri.static WebFluxMessageHandlerSpecoutboundChannelAdapter(java.lang.String uri, org.springframework.web.reactive.function.client.WebClient webClient)Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on provideduriandWebClient.static WebFluxMessageHandlerSpecoutboundChannelAdapter(java.net.URI uri)Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedURI.static WebFluxMessageHandlerSpecoutboundChannelAdapter(java.net.URI uri, org.springframework.web.reactive.function.client.WebClient webClient)Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedURIandWebClient.static <P> WebFluxMessageHandlerSpecoutboundChannelAdapter(java.util.function.Function<org.springframework.messaging.Message<P>,?> uriFunction)Create anWebFluxMessageHandlerSpecbuilder for one-way adapter based on providedFunctionto evaluate targeturiagainst request message.static <P> WebFluxMessageHandlerSpecoutboundChannelAdapter(java.util.function.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(java.lang.String uri)Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provideduri.static WebFluxMessageHandlerSpecoutboundGateway(java.lang.String uri, org.springframework.web.reactive.function.client.WebClient webClient)Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on provideduriandWebClient.static WebFluxMessageHandlerSpecoutboundGateway(java.net.URI uri)Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedURI.static WebFluxMessageHandlerSpecoutboundGateway(java.net.URI uri, org.springframework.web.reactive.function.client.WebClient webClient)Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedURIandWebClient.static <P> WebFluxMessageHandlerSpecoutboundGateway(java.util.function.Function<org.springframework.messaging.Message<P>,?> uriFunction)Create anWebFluxMessageHandlerSpecbuilder for request-reply gateway based on providedFunctionto evaluate targeturiagainst request message.static <P> WebFluxMessageHandlerSpecoutboundGateway(java.util.function.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(java.util.function.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(java.net.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(java.lang.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(java.util.function.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(java.util.function.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(java.net.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(java.lang.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(java.util.function.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
-