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 Details

    • outboundChannelAdapter

      public static WebFluxMessageHandlerSpec outboundChannelAdapter​(java.net.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​(java.lang.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<org.springframework.messaging.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​(org.springframework.expression.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​(java.net.URI uri, org.springframework.web.reactive.function.client.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​(java.lang.String uri, org.springframework.web.reactive.function.client.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<org.springframework.messaging.Message<P>,​?> uriFunction, org.springframework.web.reactive.function.client.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​(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.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​(java.net.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​(java.lang.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<org.springframework.messaging.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​(org.springframework.expression.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​(java.net.URI uri, org.springframework.web.reactive.function.client.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​(java.lang.String uri, org.springframework.web.reactive.function.client.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<org.springframework.messaging.Message<P>,​?> uriFunction, org.springframework.web.reactive.function.client.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​(org.springframework.expression.Expression uriExpression, org.springframework.web.reactive.function.client.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​(java.lang.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​(java.lang.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