Class RSockets
java.lang.Object
org.springframework.integration.rsocket.dsl.RSockets
public final class RSockets
extends java.lang.Object
The RSocket components Factory.
- Since:
- 5.2
-
Method Summary
Modifier and Type Method Description static RSocketInboundGatewaySpecinboundGateway(java.lang.String... path)Create anRSocketInboundGatewaySpecbuilder for request-reply reactive gateway based on the providedpatharray for mapping.static RSocketOutboundGatewaySpecoutboundGateway(java.lang.String route, java.lang.Object... routeVariables)Create anRSocketOutboundGatewaySpecbuilder for request-reply gateway based on providedrouteand optional variables to expand route template.static <P> RSocketOutboundGatewaySpecoutboundGateway(java.util.function.Function<org.springframework.messaging.Message<P>,?> routeFunction)Create anRSocketOutboundGatewaySpecbuilder for request-reply gateway based on providedFunctionto evaluate targetrouteagainst request message.static RSocketOutboundGatewaySpecoutboundGateway(org.springframework.expression.Expression routeExpression)Create anRSocketOutboundGatewaySpecbuilder for request-reply gateway based on provided SpELExpressionto evaluate targetrouteagainst request message.
-
Method Details
-
outboundGateway
public static RSocketOutboundGatewaySpec outboundGateway(java.lang.String route, java.lang.Object... routeVariables)Create anRSocketOutboundGatewaySpecbuilder for request-reply gateway based on providedrouteand optional variables to expand route template.- Parameters:
route- therouteto send requests.routeVariables- the variables to expand route template.- Returns:
- the RSocketOutboundGatewaySpec instance
-
outboundGateway
public static <P> RSocketOutboundGatewaySpec outboundGateway(java.util.function.Function<org.springframework.messaging.Message<P>,?> routeFunction)Create anRSocketOutboundGatewaySpecbuilder for request-reply gateway based on providedFunctionto evaluate targetrouteagainst request message.- Type Parameters:
P- the expected payload type.- Parameters:
routeFunction- theFunctionto evaluaterouteat runtime.- Returns:
- the RSocketOutboundGatewaySpec instance
-
outboundGateway
public static RSocketOutboundGatewaySpec outboundGateway(org.springframework.expression.Expression routeExpression)Create anRSocketOutboundGatewaySpecbuilder for request-reply gateway based on provided SpELExpressionto evaluate targetrouteagainst request message.- Parameters:
routeExpression- the SpELExpressionto evaluaterouteat runtime.- Returns:
- the RSocketOutboundGatewaySpec instance
-
inboundGateway
Create anRSocketInboundGatewaySpecbuilder for request-reply reactive gateway based on the providedpatharray for mapping.- Parameters:
path- the path mapping URIs (e.g. "/myPath.do").- Returns:
- the RSocketInboundGatewaySpec instance
-