Package org.springframework.integration.rsocket.outbound

Class RSocketOutboundGateway

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.MessageHandlerSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.integration.handler.AbstractReplyProducingMessageHandler

org.springframework.integration.rsocket.outbound.RSocketOutboundGateway

All Implemented Interfaces:

org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

public class RSocketOutboundGateway
extends AbstractReplyProducingMessageHandler

An Outbound Messaging Gateway for RSocket requests. The request logic is fully based on the RSocketRequester, which can be obtained from the ClientRSocketConnector on the client side or from the RSocketRequesterMethodArgumentResolver.RSOCKET_REQUESTER_HEADER request message header on the server side.

An RSocket operation is determined by the configured RSocketInteractionModel or respective SpEL expression to be evaluated at runtime against the request message. By default the RSocketInteractionModel.requestResponse operation is used.

For a Publisher-based requests, it must be present in the request message payload. The flattening via upstream FluxMessageChannel will work, too, but this way we will lose a scope of particular request and every Publisher event will be send in its own plain request.

If reply is a Flux, it is wrapped to the Mono to retain a request scope. The downstream flow is responsible to obtain this Flux from a message payload and subscribe to it by itself. The Mono reply from this component is subscribed from the downstream FluxMessageChannel or it is adapted to the ListenableFuture otherwise.

Since:

5.2

Author:

Artem Bilan

See Also:

• RSocketInteractionModel
• RSocketRequester

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

AbstractReplyProducingMessageHandler.RequestHandler

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

messagingTemplate

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
RSocketOutboundGateway(String route, Object... routeVariables)	Instantiate based on the provided RSocket endpoint route and optional variables to expand route template.
RSocketOutboundGateway(Expression routeExpression)	Instantiate based on the provided SpEL expression to evaluate an RSocket endpoint route at runtime against a request message.

Method Summary

Modifier and Type	Method	Description
protected void	doInit()
protected Object	handleRequestMessage(Message<?> requestMessage)	Subclasses must implement this method to handle the request Message.
void	setClientRSocketConnector(ClientRSocketConnector clientRSocketConnector)	Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester().
void	setExpectedResponseType(Class<?> expectedResponseType)	Specify an response type for the RSocket response.
void	setExpectedResponseTypeExpression(Expression expectedResponseTypeExpression)	Specify an Expression to determine the type for the RSocket response.
void	setInteractionModel(RSocketInteractionModel interactionModel)	Configure an RSocketInteractionModel for the RSocket request type.
void	setInteractionModelExpression(Expression interactionModelExpression)	Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
void	setMetadataExpression(Expression metadataExpression)	Specify a SpEL expression to evaluate a metadata for the RSocket request as Map<Object, MimeType> against a request message.
void	setPublisherElementType(Class<?> publisherElementType)	Configure a type for a request Publisher elements.
void	setPublisherElementTypeExpression(Expression publisherElementTypeExpression)	Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.

Methods inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply

Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, destroy, getComponentType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Details

RSocketOutboundGateway

public RSocketOutboundGateway(String route,
 @Nullable
 Object... routeVariables)

Instantiate based on the provided RSocket endpoint route and optional variables to expand route template.

Parameters:

route - the RSocket endpoint route to use.

routeVariables - the variables to expand route template.

RSocketOutboundGateway

public RSocketOutboundGateway(Expression routeExpression)

Instantiate based on the provided SpEL expression to evaluate an RSocket endpoint route at runtime against a request message. If route is a template and variables expansion is required, it is recommended to do that in this expression evaluation, for example using some bean with an appropriate logic.

Parameters:

routeExpression - the SpEL expression to use.

Method Details

setClientRSocketConnector

public void setClientRSocketConnector(ClientRSocketConnector clientRSocketConnector)

Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester(). In case of server side, an RSocketRequester must be provided in the RSocketRequesterMethodArgumentResolver.RSOCKET_REQUESTER_HEADER header of request message.

Parameters:

clientRSocketConnector - the ClientRSocketConnector to use.

setInteractionModel

public void setInteractionModel(RSocketInteractionModel interactionModel)

Configure an RSocketInteractionModel for the RSocket request type.

Parameters:

interactionModel - the RSocketInteractionModel to use.

Since:

5.2.2

setInteractionModelExpression

public void setInteractionModelExpression(Expression interactionModelExpression)

Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.

Parameters:

interactionModelExpression - the SpEL expression to use.

Since:

5.2.2

setPublisherElementType

public void setPublisherElementType(Class<?> publisherElementType)

Configure a type for a request Publisher elements.

Parameters:

publisherElementType - the type of the request Publisher elements.

See Also:

• RSocketRequester.RequestSpec.data(Object, Class)

setPublisherElementTypeExpression

public void setPublisherElementTypeExpression(Expression publisherElementTypeExpression)

Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.

Parameters:

publisherElementTypeExpression - the expression to evaluate a type for the request Publisher elements.

See Also:

• RSocketRequester.RequestSpec.data(java.lang.Object)

setExpectedResponseType

public void setExpectedResponseType(Class<?> expectedResponseType)

Specify an response type for the RSocket response.

Parameters:

expectedResponseType - The expected type.

See Also:

• setExpectedResponseTypeExpression(Expression)
• RSocketRequester.RetrieveSpec.retrieveMono(java.lang.Class<T>)
• RSocketRequester.RetrieveSpec.retrieveFlux(java.lang.Class<T>)

setExpectedResponseTypeExpression

public void setExpectedResponseTypeExpression(Expression expectedResponseTypeExpression)

Specify an Expression to determine the type for the RSocket response.

Parameters:

expectedResponseTypeExpression - The expected response type expression.

See Also:

• RSocketRequester.RetrieveSpec.retrieveMono(java.lang.Class<T>)
• RSocketRequester.RetrieveSpec.retrieveFlux(java.lang.Class<T>)

setMetadataExpression

public void setMetadataExpression(Expression metadataExpression)

Specify a SpEL expression to evaluate a metadata for the RSocket request as Map<Object, MimeType> against a request message.

Parameters:

metadataExpression - the expression for metadata.

doInit

protected void doInit()

Overrides:

doInit in class AbstractReplyProducingMessageHandler

handleRequestMessage

protected Object handleRequestMessage(Message<?> requestMessage)

Description copied from class: AbstractReplyProducingMessageHandler

Subclasses must implement this method to handle the request Message. The return value may be a Message, a MessageBuilder, or any plain Object. The base class will handle the final creation of a reply Message from any of those starting points. If the return value is null, the Message flow will end here.

Specified by:

handleRequestMessage in class AbstractReplyProducingMessageHandler

Parameters:

requestMessage - The request message.

Returns:

The result of handling the message, or null.