org.springframework.integration.rsocket.dsl

Class RSockets

java.lang.Object

org.springframework.integration.rsocket.dsl.RSockets

public final class RSockets
extends Object

The RSocket components Factory.

Since:

5.2

Author:

Artem Bilan

Method Summary

Modifier and Type	Method and Description
static RSocketInboundGatewaySpec	inboundGateway(String... path) Create an RSocketInboundGatewaySpec builder for request-reply reactive gateway based on the provided path array for mapping.
static RSocketOutboundGatewaySpec	outboundGateway(Expression routeExpression) Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided SpEL Expression to evaluate target route against request message.
static <P> RSocketOutboundGatewaySpec	outboundGateway(java.util.function.Function<Message<P>,?> routeFunction) Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided Function to evaluate target route against request message.
static RSocketOutboundGatewaySpec	outboundGateway(String route, Object... routeVariables) Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided route and optional variables to expand route template.

Methods inherited from class java.lang.Object

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

Method Detail

outboundGateway

public static RSocketOutboundGatewaySpec outboundGateway(String route,
                                                         Object... routeVariables)

Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided route and optional variables to expand route template.

Parameters:

route - the route to send requests.

routeVariables - the variables to expand route template.

Returns:

the RSocketOutboundGatewaySpec instance

outboundGateway

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

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

Type Parameters:

P - the expected payload type.

Parameters:

routeFunction - the Function to evaluate route at runtime.

Returns:

the RSocketOutboundGatewaySpec instance

outboundGateway

public static RSocketOutboundGatewaySpec outboundGateway(Expression routeExpression)

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

Parameters:

routeExpression - the SpEL Expression to evaluate route at runtime.

Returns:

the RSocketOutboundGatewaySpec instance

inboundGateway

public static RSocketInboundGatewaySpec inboundGateway(String... path)

Create an RSocketInboundGatewaySpec 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 RSocketInboundGatewaySpec instance