public class RSocketOutboundGatewaySpec extends MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>
MessageHandlerSpec implementation for the RSocketOutboundGateway.PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 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(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<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(String commandExpression)
Configure a SpEL expression to evaluate a
RSocketOutboundGateway.Command
for RSocket request type at runtime against a request message. |
RSocketOutboundGatewaySpec |
expectedResponseType(Class<?> expectedResponseType)
Specify the expected response type for the RSocket response.
|
RSocketOutboundGatewaySpec |
expectedResponseType(Expression expectedResponseTypeExpression)
Specify the
Expression to determine the type for the RSocket response. |
<P> RSocketOutboundGatewaySpec |
expectedResponseType(java.util.function.Function<Message<P>,?> expectedResponseTypeFunction)
Specify the
Function to determine the type for the RSocket response. |
RSocketOutboundGatewaySpec |
expectedResponseType(String expectedResponseTypeExpression)
Specify the
Expression to determine the type for the RSocket response. |
RSocketOutboundGatewaySpec |
metadata(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<Message<P>,Map<Object,MimeType>> metadataFunction)
Configure a
Function to evaluate a metadata as a Map<Object, MimeType>
for RSocket request against request message. |
RSocketOutboundGatewaySpec |
metadata(String metadataExpression)
Configure a SpEL expression to evaluate a metadata as a
Map<Object, MimeType>
for RSocket request against request message. |
RSocketOutboundGatewaySpec |
publisherElementType(Class<?> publisherElementType)
Configure a type for a request
Publisher elements. |
RSocketOutboundGatewaySpec |
publisherElementType(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<Message<P>,?> publisherElementTypeFunction)
Configure a
Function to evaluate a request Publisher
elements type at runtime against a request message. |
RSocketOutboundGatewaySpec |
publisherElementType(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, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonpublic 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<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(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(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(Class<?> publisherElementType)
Publisher elements.publisherElementType - the type of the request Publisher elements.RSocketOutboundGateway.setPublisherElementType(Class)public <P> RSocketOutboundGatewaySpec publisherElementType(java.util.function.Function<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(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(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(Class<?> expectedResponseType)
expectedResponseType - The expected type.RSocketOutboundGateway.setExpectedResponseType(Class)public <P> RSocketOutboundGatewaySpec expectedResponseType(java.util.function.Function<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(String expectedResponseTypeExpression)
Expression to determine the type for the RSocket response.expectedResponseTypeExpression - The expected response type expression.RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)public RSocketOutboundGatewaySpec expectedResponseType(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<Message<P>,Map<Object,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(String metadataExpression)
Map<Object, MimeType>
for RSocket request against request message.metadataExpression - the SpEL expression to use.RSocketOutboundGateway.setMetadataExpression(Expression)public RSocketOutboundGatewaySpec metadata(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)