public class RSocketOutboundGatewaySpec extends MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>
MessageHandlerSpec
implementation for the RSocketOutboundGateway
.PARSER, target
logger
DEFAULT_PHASE
OBJECT_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)
Deprecated.
in favor of
interactionModel(Expression) |
<P> RSocketOutboundGatewaySpec |
command(java.util.function.Function<Message<P>,?> commandFunction)
Deprecated.
in favor of
interactionModel(Function) |
RSocketOutboundGatewaySpec |
command(RSocketOutboundGateway.Command command)
Deprecated.
in favor of
interactionModel(RSocketInteractionModel) |
RSocketOutboundGatewaySpec |
command(String commandExpression)
Deprecated.
in favor of
interactionModel(String) |
RSocketOutboundGatewaySpec |
expectedResponseType(Class<?> expectedResponseType)
Specify the expected response type for the RSocket response.
|
RSocketOutboundGatewaySpec |
expectedResponseType(Expression expectedResponseTypeExpression)
Specify an
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 |
interactionModel(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<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(String interactionModelExpression)
Configure a SpEL expression to evaluate an
RSocketInteractionModel
for the RSocket request type at runtime against a request message. |
RSocketOutboundGatewaySpec |
metadata(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<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 the 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, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
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)
@Deprecated public RSocketOutboundGatewaySpec command(RSocketOutboundGateway.Command command)
interactionModel(RSocketInteractionModel)
RSocketOutboundGateway.Command
for the RSocket request type.command
- the RSocketOutboundGateway.Command
to use.RSocketOutboundGateway.setCommand(RSocketOutboundGateway.Command)
public RSocketOutboundGatewaySpec interactionModel(RSocketInteractionModel interactionModel)
RSocketInteractionModel
for the RSocket request type.interactionModel
- the RSocketInteractionModel
to use.RSocketOutboundGateway.setInteractionModel(RSocketInteractionModel)
@Deprecated public <P> RSocketOutboundGatewaySpec command(java.util.function.Function<Message<P>,?> commandFunction)
interactionModel(Function)
Function
to evaluate an RSocketOutboundGateway.Command
for the RSocket request type at runtime against a request message.P
- the expected request message payload type.commandFunction
- the Function
to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)
public <P> RSocketOutboundGatewaySpec interactionModel(java.util.function.Function<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)
@Deprecated public RSocketOutboundGatewaySpec command(String commandExpression)
interactionModel(String)
RSocketOutboundGateway.Command
for the RSocket request type at runtime against a request message.commandExpression
- the SpEL expression to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)
public RSocketOutboundGatewaySpec interactionModel(String interactionModelExpression)
RSocketInteractionModel
for the RSocket request type at runtime against a request message.interactionModelExpression
- the SpEL expression to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)
@Deprecated public RSocketOutboundGatewaySpec command(Expression commandExpression)
interactionModel(Expression)
RSocketOutboundGateway.Command
for the RSocket request type at runtime against a request message.commandExpression
- the SpEL expression to use.RSocketOutboundGateway.setInteractionModelExpression(Expression)
public RSocketOutboundGatewaySpec interactionModel(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(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 the RSocket request against request message.metadataExpression
- the SpEL expression to use.RSocketOutboundGateway.setMetadataExpression(Expression)
public RSocketOutboundGatewaySpec metadata(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)