public class RSocketOutboundGatewaySpec extends org.springframework.integration.dsl.MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>
MessageHandlerSpec implementation for the RSocketOutboundGateway.| Modifier | Constructor and Description |
|---|---|
protected |
RSocketOutboundGatewaySpec(org.springframework.expression.Expression routeExpression) |
protected |
RSocketOutboundGatewaySpec(java.lang.String route,
java.lang.Object... routeVariables) |
| Modifier and Type | Method and Description |
|---|---|
RSocketOutboundGatewaySpec |
clientRSocketConnector(ClientRSocketConnector clientRSocketConnector)
Configure a
ClientRSocketConnector for client side requests based on the connection
provided by the ClientRSocketConnector.getRSocketRequester(). |
RSocketOutboundGatewaySpec |
expectedResponseType(java.lang.Class<?> expectedResponseType)
Specify the expected response type for the RSocket response.
|
RSocketOutboundGatewaySpec |
expectedResponseType(org.springframework.expression.Expression expectedResponseTypeExpression)
Specify an
Expression to determine the type for the RSocket response. |
<P> RSocketOutboundGatewaySpec |
expectedResponseType(java.util.function.Function<org.springframework.messaging.Message<P>,?> expectedResponseTypeFunction)
Specify the
Function to determine the type for the RSocket response. |
RSocketOutboundGatewaySpec |
expectedResponseType(java.lang.String expectedResponseTypeExpression)
Specify the
Expression to determine the type for the RSocket response. |
RSocketOutboundGatewaySpec |
interactionModel(org.springframework.expression.Expression interactionModelExpression)
Configure a SpEL expression to evaluate an
RSocketInteractionModel
for the RSocket request type at runtime against a request message. |
<P> RSocketOutboundGatewaySpec |
interactionModel(java.util.function.Function<org.springframework.messaging.Message<P>,?> interactionModelFunction)
Configure a
Function to evaluate an RSocketInteractionModel
for the RSocket request type at runtime against a request message. |
RSocketOutboundGatewaySpec |
interactionModel(RSocketInteractionModel interactionModel)
Configure an
RSocketInteractionModel for the RSocket request type. |
RSocketOutboundGatewaySpec |
interactionModel(java.lang.String interactionModelExpression)
Configure a SpEL expression to evaluate an
RSocketInteractionModel
for the RSocket request type at runtime against a request message. |
RSocketOutboundGatewaySpec |
metadata(org.springframework.expression.Expression metadataExpression)
Configure a SpEL expression to evaluate a metadata as a
Map<Object, MimeType>
for the RSocket request type at runtime against a request message. |
<P> RSocketOutboundGatewaySpec |
metadata(java.util.function.Function<org.springframework.messaging.Message<P>,java.util.Map<java.lang.Object,org.springframework.util.MimeType>> metadataFunction)
Configure a
Function to evaluate a metadata as a Map<Object, MimeType>
for RSocket request against request message. |
RSocketOutboundGatewaySpec |
metadata(java.lang.String metadataExpression)
Configure a SpEL expression to evaluate a metadata as a
Map<Object, MimeType>
for the RSocket request against request message. |
RSocketOutboundGatewaySpec |
publisherElementType(java.lang.Class<?> publisherElementType)
Configure a type for a request
Publisher elements. |
RSocketOutboundGatewaySpec |
publisherElementType(org.springframework.expression.Expression publisherElementTypeExpression)
Configure a SpEL expression to evaluate a request
Publisher
elements type at runtime against a request message. |
<P> RSocketOutboundGatewaySpec |
publisherElementType(java.util.function.Function<org.springframework.messaging.Message<P>,?> publisherElementTypeFunction)
Configure a
Function to evaluate a request Publisher
elements type at runtime against a request message. |
RSocketOutboundGatewaySpec |
publisherElementType(java.lang.String publisherElementTypeExpression)
Configure a SpEL expression to evaluate a request
Publisher
elements type at runtime against a request message. |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopprotected RSocketOutboundGatewaySpec(java.lang.String route,
java.lang.Object... routeVariables)
protected RSocketOutboundGatewaySpec(org.springframework.expression.Expression routeExpression)
public RSocketOutboundGatewaySpec clientRSocketConnector(ClientRSocketConnector clientRSocketConnector)
ClientRSocketConnector for client side requests based on the connection
provided by the ClientRSocketConnector.getRSocketRequester().clientRSocketConnector - the ClientRSocketConnector to use.RSocketOutboundGateway.setClientRSocketConnector(ClientRSocketConnector)public RSocketOutboundGatewaySpec interactionModel(RSocketInteractionModel interactionModel)
RSocketInteractionModel for the RSocket request type.interactionModel - the RSocketInteractionModel to use.RSocketOutboundGateway.setInteractionModel(RSocketInteractionModel)public <P> RSocketOutboundGatewaySpec interactionModel(java.util.function.Function<org.springframework.messaging.Message<P>,?> interactionModelFunction)
Function to evaluate an RSocketInteractionModel
for the RSocket request type at runtime against a request message.P - the expected request message payload type.interactionModelFunction - the Function to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)public RSocketOutboundGatewaySpec interactionModel(java.lang.String interactionModelExpression)
RSocketInteractionModel
for the RSocket request type at runtime against a request message.interactionModelExpression - the SpEL expression to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)public RSocketOutboundGatewaySpec interactionModel(org.springframework.expression.Expression interactionModelExpression)
RSocketInteractionModel
for the RSocket request type at runtime against a request message.interactionModelExpression - the SpEL expression to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)public RSocketOutboundGatewaySpec publisherElementType(java.lang.Class<?> publisherElementType)
Publisher elements.publisherElementType - the type of the request Publisher elements.RSocketOutboundGateway.setPublisherElementType(Class)public <P> RSocketOutboundGatewaySpec publisherElementType(java.util.function.Function<org.springframework.messaging.Message<P>,?> publisherElementTypeFunction)
Function to evaluate a request Publisher
elements type at runtime against a request message.P - the expected request message payload type.publisherElementTypeFunction - the Function to evaluate a type for the request
Publisher elements.RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)public RSocketOutboundGatewaySpec publisherElementType(java.lang.String publisherElementTypeExpression)
Publisher
elements type at runtime against a request message.publisherElementTypeExpression - the expression to evaluate a type for the request
Publisher elements.RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)public RSocketOutboundGatewaySpec publisherElementType(org.springframework.expression.Expression publisherElementTypeExpression)
Publisher
elements type at runtime against a request message.publisherElementTypeExpression - the expression to evaluate a type for the request
Publisher elements.RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)public RSocketOutboundGatewaySpec expectedResponseType(java.lang.Class<?> expectedResponseType)
expectedResponseType - The expected type.RSocketOutboundGateway.setExpectedResponseType(Class)public <P> RSocketOutboundGatewaySpec expectedResponseType(java.util.function.Function<org.springframework.messaging.Message<P>,?> expectedResponseTypeFunction)
Function to determine the type for the RSocket response.P - the expected request message payload type.expectedResponseTypeFunction - The expected response type Function.RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)public RSocketOutboundGatewaySpec expectedResponseType(java.lang.String expectedResponseTypeExpression)
Expression to determine the type for the RSocket response.expectedResponseTypeExpression - The expected response type expression.RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)public RSocketOutboundGatewaySpec expectedResponseType(org.springframework.expression.Expression expectedResponseTypeExpression)
Expression to determine the type for the RSocket response.expectedResponseTypeExpression - The expected response type expression.RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)public <P> RSocketOutboundGatewaySpec metadata(java.util.function.Function<org.springframework.messaging.Message<P>,java.util.Map<java.lang.Object,org.springframework.util.MimeType>> metadataFunction)
Function to evaluate a metadata as a Map<Object, MimeType>
for RSocket request against request message.P - the expected request message payload type.metadataFunction - the Function to use.RSocketOutboundGateway.setMetadataExpression(Expression)public RSocketOutboundGatewaySpec metadata(java.lang.String metadataExpression)
Map<Object, MimeType>
for the RSocket request against request message.metadataExpression - the SpEL expression to use.RSocketOutboundGateway.setMetadataExpression(Expression)public RSocketOutboundGatewaySpec metadata(org.springframework.expression.Expression metadataExpression)
Map<Object, MimeType>
for the RSocket request type at runtime against a request message.metadataExpression - the SpEL expression to use.RSocketOutboundGateway.setMetadataExpression(Expression)