org.springframework.integration.webflux.dsl

Class WebFlux

java.lang.Object

org.springframework.integration.webflux.dsl.WebFlux

public final class WebFlux
extends Object

The WebFlux components Factory.

Since:

5.0

Author:

Artem Bilan, Shiliang Li

Method Summary

Modifier and Type	Method and Description
static WebFluxInboundEndpointSpec	inboundChannelAdapter(String... path) Create an WebFluxInboundEndpointSpec builder for one-way reactive adapter based on the provided path array for mapping.
static WebFluxInboundEndpointSpec	inboundGateway(String... path) Create an WebFluxInboundEndpointSpec builder for request-reply reactive gateway based on the provided path array for mapping.
static WebFluxMessageHandlerSpec	outboundChannelAdapter(Expression uriExpression) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided SpEL Expression to evaluate target uri against request message.
static WebFluxMessageHandlerSpec	outboundChannelAdapter(Expression uriExpression, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided SpEL Expression to evaluate target uri against request message and WebClient for HTTP exchanges.
static <P> WebFluxMessageHandlerSpec	outboundChannelAdapter(java.util.function.Function<Message<P>,?> uriFunction) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided Function to evaluate target uri against request message.
static <P> WebFluxMessageHandlerSpec	outboundChannelAdapter(java.util.function.Function<Message<P>,?> uriFunction, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided Function to evaluate target uri against request message and WebClient for HTTP exchanges.
static WebFluxMessageHandlerSpec	outboundChannelAdapter(String uri) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided uri.
static WebFluxMessageHandlerSpec	outboundChannelAdapter(String uri, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided uri and WebClient.
static WebFluxMessageHandlerSpec	outboundChannelAdapter(URI uri) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided URI.
static WebFluxMessageHandlerSpec	outboundChannelAdapter(URI uri, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided URI and WebClient.
static WebFluxMessageHandlerSpec	outboundGateway(Expression uriExpression) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided SpEL Expression to evaluate target uri against request message.
static WebFluxMessageHandlerSpec	outboundGateway(Expression uriExpression, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided SpEL Expression to evaluate target uri against request message and WebClient for HTTP exchanges.
static <P> WebFluxMessageHandlerSpec	outboundGateway(java.util.function.Function<Message<P>,?> uriFunction) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided Function to evaluate target uri against request message.
static <P> WebFluxMessageHandlerSpec	outboundGateway(java.util.function.Function<Message<P>,?> uriFunction, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided Function to evaluate target uri against request message and WebClient for HTTP exchanges.
static WebFluxMessageHandlerSpec	outboundGateway(String uri) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided uri.
static WebFluxMessageHandlerSpec	outboundGateway(String uri, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided uri and WebClient.
static WebFluxMessageHandlerSpec	outboundGateway(URI uri) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided URI.
static WebFluxMessageHandlerSpec	outboundGateway(URI uri, WebClient webClient) Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided URI and WebClient.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

outboundChannelAdapter

public static WebFluxMessageHandlerSpec outboundChannelAdapter(URI uri)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided URI.

Parameters:

uri - the URI to send requests.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static WebFluxMessageHandlerSpec outboundChannelAdapter(String uri)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided uri.

Parameters:

uri - the uri to send requests.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static <P> WebFluxMessageHandlerSpec outboundChannelAdapter(java.util.function.Function<Message<P>,?> uriFunction)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided Function to evaluate target uri against request message.

Type Parameters:

P - the expected payload type.

Parameters:

uriFunction - the Function to evaluate uri at runtime.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static WebFluxMessageHandlerSpec outboundChannelAdapter(Expression uriExpression)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided SpEL Expression to evaluate target uri against request message.

Parameters:

uriExpression - the SpEL Expression to evaluate uri at runtime.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static WebFluxMessageHandlerSpec outboundChannelAdapter(URI uri,
                                                               WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided URI and WebClient.

Parameters:

uri - the URI to send requests.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static WebFluxMessageHandlerSpec outboundChannelAdapter(String uri,
                                                               WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided uri and WebClient.

Parameters:

uri - the uri to send requests.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static <P> WebFluxMessageHandlerSpec outboundChannelAdapter(java.util.function.Function<Message<P>,?> uriFunction,
                                                                   WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided Function to evaluate target uri against request message and WebClient for HTTP exchanges.

Type Parameters:

P - the expected payload type.

Parameters:

uriFunction - the Function to evaluate uri at runtime.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundChannelAdapter

public static WebFluxMessageHandlerSpec outboundChannelAdapter(Expression uriExpression,
                                                               WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for one-way adapter based on provided SpEL Expression to evaluate target uri against request message and WebClient for HTTP exchanges.

Parameters:

uriExpression - the SpEL Expression to evaluate uri at runtime.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static WebFluxMessageHandlerSpec outboundGateway(URI uri)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided URI.

Parameters:

uri - the URI to send requests.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static WebFluxMessageHandlerSpec outboundGateway(String uri)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided uri.

Parameters:

uri - the uri to send requests.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static <P> WebFluxMessageHandlerSpec outboundGateway(java.util.function.Function<Message<P>,?> uriFunction)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided Function to evaluate target uri against request message.

Type Parameters:

P - the expected payload type.

Parameters:

uriFunction - the Function to evaluate uri at runtime.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static WebFluxMessageHandlerSpec outboundGateway(Expression uriExpression)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided SpEL Expression to evaluate target uri against request message.

Parameters:

uriExpression - the SpEL Expression to evaluate uri at runtime.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static WebFluxMessageHandlerSpec outboundGateway(URI uri,
                                                        WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided URI and WebClient.

Parameters:

uri - the URI to send requests.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static WebFluxMessageHandlerSpec outboundGateway(String uri,
                                                        WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided uri and WebClient.

Parameters:

uri - the uri to send requests.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static <P> WebFluxMessageHandlerSpec outboundGateway(java.util.function.Function<Message<P>,?> uriFunction,
                                                            WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided Function to evaluate target uri against request message and WebClient for HTTP exchanges.

Type Parameters:

P - the expected payload type.

Parameters:

uriFunction - the Function to evaluate uri at runtime.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

outboundGateway

public static WebFluxMessageHandlerSpec outboundGateway(Expression uriExpression,
                                                        WebClient webClient)

Create an WebFluxMessageHandlerSpec builder for request-reply gateway based on provided SpEL Expression to evaluate target uri against request message and WebClient for HTTP exchanges.

Parameters:

uriExpression - the SpEL Expression to evaluate uri at runtime.

webClient - WebClient to use.

Returns:

the WebFluxMessageHandlerSpec instance

inboundChannelAdapter

public static WebFluxInboundEndpointSpec inboundChannelAdapter(String... path)

Create an WebFluxInboundEndpointSpec builder for one-way reactive adapter based on the provided path array for mapping.

Parameters:

path - the path mapping URIs (e.g. "/myPath.do").

Returns:

the WebFluxInboundEndpointSpec instance

inboundGateway

public static WebFluxInboundEndpointSpec inboundGateway(String... path)

Create an WebFluxInboundEndpointSpec builder for request-reply reactive gateway based on the provided path array for mapping.

Parameters:

path - the path mapping URIs (e.g. "/myPath.do").

Returns:

the WebFluxInboundEndpointSpec instance