Class RSocketOutboundGatewaySpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>
org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<RSocketOutboundGateway>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class RSocketOutboundGatewaySpec extends org.springframework.integration.dsl.MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>
The
MessageHandlerSpec implementation for the RSocketOutboundGateway.- Since:
- 5.2
-
Field Summary
-
Constructor Summary
Constructors Modifier Constructor Description protectedRSocketOutboundGatewaySpec(java.lang.String route, java.lang.Object... routeVariables)protectedRSocketOutboundGatewaySpec(org.springframework.expression.Expression routeExpression) -
Method Summary
Modifier and Type Method Description RSocketOutboundGatewaySpecclientRSocketConnector(ClientRSocketConnector clientRSocketConnector)Configure aClientRSocketConnectorfor client side requests based on the connection provided by theClientRSocketConnector.getRequester().RSocketOutboundGatewaySpecexpectedResponseType(java.lang.Class<?> expectedResponseType)Specify the expected response type for the RSocket response.RSocketOutboundGatewaySpecexpectedResponseType(java.lang.String expectedResponseTypeExpression)Specify theExpressionto determine the type for the RSocket response.<P> RSocketOutboundGatewaySpecexpectedResponseType(java.util.function.Function<org.springframework.messaging.Message<P>,?> expectedResponseTypeFunction)Specify theFunctionto determine the type for the RSocket response.RSocketOutboundGatewaySpecexpectedResponseType(org.springframework.expression.Expression expectedResponseTypeExpression)Specify anExpressionto determine the type for the RSocket response.RSocketOutboundGatewaySpecinteractionModel(java.lang.String interactionModelExpression)Configure a SpEL expression to evaluate anRSocketInteractionModelfor the RSocket request type at runtime against a request message.<P> RSocketOutboundGatewaySpecinteractionModel(java.util.function.Function<org.springframework.messaging.Message<P>,?> interactionModelFunction)Configure aFunctionto evaluate anRSocketInteractionModelfor the RSocket request type at runtime against a request message.RSocketOutboundGatewaySpecinteractionModel(org.springframework.expression.Expression interactionModelExpression)Configure a SpEL expression to evaluate anRSocketInteractionModelfor the RSocket request type at runtime against a request message.RSocketOutboundGatewaySpecinteractionModel(RSocketInteractionModel interactionModel)Configure anRSocketInteractionModelfor the RSocket request type.RSocketOutboundGatewaySpecmetadata(java.lang.String metadataExpression)Configure a SpEL expression to evaluate a metadata as aMap<Object, MimeType>for the RSocket request against request message.<P> RSocketOutboundGatewaySpecmetadata(java.util.function.Function<org.springframework.messaging.Message<P>,java.util.Map<java.lang.Object,org.springframework.util.MimeType>> metadataFunction)Configure aFunctionto evaluate a metadata as aMap<Object, MimeType>for RSocket request against request message.RSocketOutboundGatewaySpecmetadata(org.springframework.expression.Expression metadataExpression)Configure a SpEL expression to evaluate a metadata as aMap<Object, MimeType>for the RSocket request type at runtime against a request message.RSocketOutboundGatewaySpecpublisherElementType(java.lang.Class<?> publisherElementType)Configure a type for a requestPublisherelements.RSocketOutboundGatewaySpecpublisherElementType(java.lang.String publisherElementTypeExpression)Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.<P> RSocketOutboundGatewaySpecpublisherElementType(java.util.function.Function<org.springframework.messaging.Message<P>,?> publisherElementTypeFunction)Configure aFunctionto evaluate a requestPublisherelements type at runtime against a request message.RSocketOutboundGatewaySpecpublisherElementType(org.springframework.expression.Expression publisherElementTypeExpression)Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
-
Constructor Details
-
RSocketOutboundGatewaySpec
protected RSocketOutboundGatewaySpec(java.lang.String route, java.lang.Object... routeVariables) -
RSocketOutboundGatewaySpec
protected RSocketOutboundGatewaySpec(org.springframework.expression.Expression routeExpression)
-
-
Method Details
-
clientRSocketConnector
public RSocketOutboundGatewaySpec clientRSocketConnector(ClientRSocketConnector clientRSocketConnector)Configure aClientRSocketConnectorfor client side requests based on the connection provided by theClientRSocketConnector.getRequester().- Parameters:
clientRSocketConnector- theClientRSocketConnectorto use.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setClientRSocketConnector(ClientRSocketConnector)
-
interactionModel
Configure anRSocketInteractionModelfor the RSocket request type.- Parameters:
interactionModel- theRSocketInteractionModelto use.- Returns:
- the spec
- Since:
- 5.2.2
- See Also:
RSocketOutboundGateway.setInteractionModel(RSocketInteractionModel)
-
interactionModel
public <P> RSocketOutboundGatewaySpec interactionModel(java.util.function.Function<org.springframework.messaging.Message<P>,?> interactionModelFunction)Configure aFunctionto evaluate anRSocketInteractionModelfor the RSocket request type at runtime against a request message.- Type Parameters:
P- the expected request message payload type.- Parameters:
interactionModelFunction- theFunctionto use.- Returns:
- the spec
- Since:
- 5.2.2
- See Also:
RSocketOutboundGateway.setInteractionModelExpression(Expression)
-
interactionModel
Configure a SpEL expression to evaluate anRSocketInteractionModelfor the RSocket request type at runtime against a request message.- Parameters:
interactionModelExpression- the SpEL expression to use.- Returns:
- the spec
- Since:
- 5.2.2
- See Also:
RSocketOutboundGateway.setInteractionModelExpression(Expression)
-
interactionModel
public RSocketOutboundGatewaySpec interactionModel(org.springframework.expression.Expression interactionModelExpression)Configure a SpEL expression to evaluate anRSocketInteractionModelfor the RSocket request type at runtime against a request message.- Parameters:
interactionModelExpression- the SpEL expression to use.- Returns:
- the spec
- Since:
- 5.2.2
- See Also:
RSocketOutboundGateway.setInteractionModelExpression(Expression)
-
publisherElementType
Configure a type for a requestPublisherelements.- Parameters:
publisherElementType- the type of the requestPublisherelements.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setPublisherElementType(Class)
-
publisherElementType
public <P> RSocketOutboundGatewaySpec publisherElementType(java.util.function.Function<org.springframework.messaging.Message<P>,?> publisherElementTypeFunction)Configure aFunctionto evaluate a requestPublisherelements type at runtime against a request message.- Type Parameters:
P- the expected request message payload type.- Parameters:
publisherElementTypeFunction- theFunctionto evaluate a type for the requestPublisherelements.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)
-
publisherElementType
public RSocketOutboundGatewaySpec publisherElementType(java.lang.String publisherElementTypeExpression)Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.- Parameters:
publisherElementTypeExpression- the expression to evaluate a type for the requestPublisherelements.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)
-
publisherElementType
public RSocketOutboundGatewaySpec publisherElementType(org.springframework.expression.Expression publisherElementTypeExpression)Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.- Parameters:
publisherElementTypeExpression- the expression to evaluate a type for the requestPublisherelements.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)
-
expectedResponseType
Specify the expected response type for the RSocket response.- Parameters:
expectedResponseType- The expected type.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setExpectedResponseType(Class)
-
expectedResponseType
public <P> RSocketOutboundGatewaySpec expectedResponseType(java.util.function.Function<org.springframework.messaging.Message<P>,?> expectedResponseTypeFunction)Specify theFunctionto determine the type for the RSocket response.- Type Parameters:
P- the expected request message payload type.- Parameters:
expectedResponseTypeFunction- The expected response typeFunction.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)
-
expectedResponseType
public RSocketOutboundGatewaySpec expectedResponseType(java.lang.String expectedResponseTypeExpression)Specify theExpressionto determine the type for the RSocket response.- Parameters:
expectedResponseTypeExpression- The expected response type expression.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)
-
expectedResponseType
public RSocketOutboundGatewaySpec expectedResponseType(org.springframework.expression.Expression expectedResponseTypeExpression)Specify anExpressionto determine the type for the RSocket response.- Parameters:
expectedResponseTypeExpression- The expected response type expression.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)
-
metadata
public <P> RSocketOutboundGatewaySpec metadata(java.util.function.Function<org.springframework.messaging.Message<P>,java.util.Map<java.lang.Object,org.springframework.util.MimeType>> metadataFunction)Configure aFunctionto evaluate a metadata as aMap<Object, MimeType>for RSocket request against request message.- Type Parameters:
P- the expected request message payload type.- Parameters:
metadataFunction- theFunctionto use.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setMetadataExpression(Expression)
-
metadata
Configure a SpEL expression to evaluate a metadata as aMap<Object, MimeType>for the RSocket request against request message.- Parameters:
metadataExpression- the SpEL expression to use.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setMetadataExpression(Expression)
-
metadata
public RSocketOutboundGatewaySpec metadata(org.springframework.expression.Expression metadataExpression)Configure a SpEL expression to evaluate a metadata as aMap<Object, MimeType>for the RSocket request type at runtime against a request message.- Parameters:
metadataExpression- the SpEL expression to use.- Returns:
- the spec
- See Also:
RSocketOutboundGateway.setMetadataExpression(Expression)
-