org.springframework.integration.rsocket

Class ServerRSocketMessageHandler

java.lang.Object

org.springframework.messaging.handler.invocation.reactive.AbstractMethodMessageHandler<CompositeMessageCondition>

org.springframework.messaging.handler.annotation.reactive.MessageMappingMessageHandler

org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler

org.springframework.integration.rsocket.ServerRSocketMessageHandler

All Implemented Interfaces:

Aware, BeanNameAware, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, EmbeddedValueResolverAware, ReactiveMessageHandler

public class ServerRSocketMessageHandler
extends RSocketMessageHandler
implements ApplicationEventPublisherAware

An IntegrationRSocketMessageHandler extension for RSocket service side.

In a plain Spring Integration application instances of this class are created by the ServerRSocketConnector internally and a new RSocket server is started over there. When an existing RSocket server is in use, an instance of this class has to be provided as a RSocketMessageHandler.responder() into that server and a ServerRSocketConnector should accept the same instance as a delegate.

With a messageMappingCompatible option this class also handles MessageMapping methods, covering both Spring Integration and standard RSocketMessageHandler functionality.

Since:

5.2.1

Author:

Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	org.springframework.integration.rsocket.IntegrationRSocketMessageHandler.MessageHandlerMethodArgumentResolver

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	messageMappingCompatible

Fields inherited from class org.springframework.messaging.handler.invocation.reactive.AbstractMethodMessageHandler

logger

Constructor Summary

Constructors

Constructor and Description
ServerRSocketMessageHandler() Create an service side RSocket message handler instance for delegating to IntegrationRSocketEndpoint beans and collect RSocketRequesters from client connections.
ServerRSocketMessageHandler(boolean messageMappingCompatible) Create an service side RSocket message handler instance for delegating to IntegrationRSocketEndpoint beans and collect RSocketRequesters from client connections.

Method Summary

Modifier and Type	Method and Description
void	addEndpoint(IntegrationRSocketEndpoint endpoint)
boolean	detectEndpoints()
RSocketRequester	getClientRSocketRequester(Object key) Obtain a connected RSocketRequester mapped by provided key or null.
Map<Object,RSocketRequester>	getClientRSocketRequesters() Get connected RSocketRequesters mapped by the keys from the connect messages.
protected List<? extends HandlerMethodArgumentResolver>	initArgumentResolvers()
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setClientRSocketKeyStrategy(java.util.function.BiFunction<Map<String,Object>,DataBuffer,Object> clientRSocketKeyStrategy) Configure a BiFunction to extract a key for mapping connected RSocketRequesters.

Methods inherited from class org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler

afterPropertiesSet, clientResponder, extendMapping, getCondition, getDefaultDataMimeType, getDefaultMetadataMimeType, getEncoders, getMetadataExtractor, getRSocketStrategies, handleNoMatch, initReturnValueHandlers, responder, setDecoders, setDefaultDataMimeType, setDefaultMetadataMimeType, setEncoders, setMetadataExtractor, setReactiveAdapterRegistry, setRouteMatcher, setRSocketStrategies

Methods inherited from class org.springframework.messaging.handler.annotation.reactive.MessageMappingMessageHandler

createExceptionMethodResolverFor, getConversionService, getDecoders, getDestination, getDirectLookupMappings, getMappingComparator, getMappingForMethod, getMatchingMapping, getRouteMatcher, getValidator, handleMatch, obtainRouteMatcher, processDestinations, setConversionService, setEmbeddedValueResolver, setValidator

Methods inherited from class org.springframework.messaging.handler.invocation.reactive.AbstractMethodMessageHandler

detectHandlerMethods, getApplicationContext, getArgumentResolverConfigurer, getArgumentResolvers, getBeanName, getDestinationLookup, getHandlerMethods, getHandlerPredicate, getReactiveAdapterRegistry, getReturnValueHandlerConfigurer, handleMessage, registerExceptionHandlerAdvice, registerHandlerMethod, setApplicationContext, setArgumentResolverConfigurer, setBeanName, setHandlerPredicate, setHandlers, setReturnValueHandlerConfigurer

Methods inherited from class java.lang.Object

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

Field Detail

messageMappingCompatible

protected final boolean messageMappingCompatible

Constructor Detail

ServerRSocketMessageHandler

public ServerRSocketMessageHandler()

Create an service side RSocket message handler instance for delegating to IntegrationRSocketEndpoint beans and collect RSocketRequesters from client connections.

ServerRSocketMessageHandler

public ServerRSocketMessageHandler(boolean messageMappingCompatible)

Create an service side RSocket message handler instance for delegating to IntegrationRSocketEndpoint beans and collect RSocketRequesters from client connections. When messageMappingCompatible == true, this class also handles MessageMapping methods as it is done by the standard RSocketMessageHandler.

Parameters:

messageMappingCompatible - whether handle also MessageMapping.

Method Detail

setClientRSocketKeyStrategy

public void setClientRSocketKeyStrategy(java.util.function.BiFunction<Map<String,Object>,DataBuffer,Object> clientRSocketKeyStrategy)

Configure a BiFunction to extract a key for mapping connected RSocketRequesters. Defaults to the destination a client is connected.

Parameters:

clientRSocketKeyStrategy - the BiFunction to use.

getClientRSocketRequesters

public Map<Object,RSocketRequester> getClientRSocketRequesters()

Get connected RSocketRequesters mapped by the keys from the connect messages.

Returns:

the map of connected RSocketRequesters.

See Also:

setClientRSocketKeyStrategy(java.util.function.BiFunction<java.util.Map<java.lang.String, java.lang.Object>, org.springframework.core.io.buffer.DataBuffer, java.lang.Object>)

getClientRSocketRequester

@Nullable
public RSocketRequester getClientRSocketRequester(Object key)

Obtain a connected RSocketRequester mapped by provided key or null.

Parameters:

key - the key for mapped RSocketRequester if any.

Returns:

the mapped RSocketRequester or null.

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

detectEndpoints

public boolean detectEndpoints()

addEndpoint

public void addEndpoint(IntegrationRSocketEndpoint endpoint)

initArgumentResolvers

protected List<? extends HandlerMethodArgumentResolver> initArgumentResolvers()

Overrides:

initArgumentResolvers in class MessageMappingMessageHandler