public class RSocketOutboundGatewaySpec extends org.springframework.integration.dsl.MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>
MessageHandlerSpec implementation for the RSocketOutboundGateway.| 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 |
command(org.springframework.expression.Expression commandExpression)
Configure a SpEL expression to evaluate a
RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message. |
<P> RSocketOutboundGatewaySpec |
command(java.util.function.Function<org.springframework.messaging.Message<P>,?> commandFunction)
Configure a
Function to evaluate a RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message. |
RSocketOutboundGatewaySpec |
command(RSocketOutboundGateway.Command command)
Configure a
RSocketOutboundGateway.Command for RSocket request type. |
RSocketOutboundGatewaySpec |
command(java.lang.String commandExpression)
Configure a SpEL expression to evaluate a
RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message. |
RSocketOutboundGatewaySpec |
expectedResponseType(java.lang.Class<?> expectedResponseType)
Specify the expected response type for the RSocket response.
|
RSocketOutboundGatewaySpec |
expectedResponseType(org.springframework.expression.Expression expectedResponseTypeExpression)
Specify the
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 |
metadata(org.springframework.expression.Expression metadataExpression)
Configure a SpEL expression to evaluate a metadata as a
Map<Object, MimeType>
for RSocket request against 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 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, stoppublic 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 command(RSocketOutboundGateway.Command command)
RSocketOutboundGateway.Command for RSocket request type.command - the RSocketOutboundGateway.Command to use.RSocketOutboundGateway.setCommand(RSocketOutboundGateway.Command)public <P> RSocketOutboundGatewaySpec command(java.util.function.Function<org.springframework.messaging.Message<P>,?> commandFunction)
Function to evaluate a RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message.P - the expected request message payload type.commandFunction - the Function to use.RSocketOutboundGateway.setCommandExpression(Expression)public RSocketOutboundGatewaySpec command(java.lang.String commandExpression)
RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message.commandExpression - the SpEL expression to use.RSocketOutboundGateway.setCommandExpression(Expression)public RSocketOutboundGatewaySpec command(org.springframework.expression.Expression commandExpression)
RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message.commandExpression - the SpEL expression to use.RSocketOutboundGateway.setCommandExpression(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 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 RSocket request against request message.
for RSocket request type at runtime against a request message.metadataExpression - the SpEL expression to use.RSocketOutboundGateway.setMetadataExpression(Expression)