org.springframework.messaging.rsocket

Class MessageHandlerAcceptor

java.lang.Object

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

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

org.springframework.messaging.rsocket.RSocketMessageHandler

org.springframework.messaging.rsocket.MessageHandlerAcceptor

All Implemented Interfaces:

java.util.function.Function<RSocket,RSocket>, Aware, BeanNameAware, InitializingBean, ApplicationContextAware, EmbeddedValueResolverAware, ReactiveMessageHandler

public final class MessageHandlerAcceptor
extends RSocketMessageHandler
implements java.util.function.Function<RSocket,RSocket>

Extension of RSocketMessageHandler that can be plugged directly into RSocket to receive connections either on the client or on the server side. Requests are handled by delegating to the "super" AbstractMethodMessageHandler.handleMessage(Message).

Since:

5.2

Author:

Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
private MimeType	defaultDataMimeType

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

logger

Constructor Summary

Constructors

Constructor and Description
MessageHandlerAcceptor()

Method Summary

Modifier and Type	Method and Description
<any>	accept(ConnectionSetupPayload setupPayload, RSocket sendingRSocket)
RSocket	apply(RSocket sendingRSocket)
private MessagingRSocket	createRSocket(RSocket rsocket)
void	setDefaultDataMimeType(MimeType defaultDataMimeType) Configure the default content type to use for data payloads.

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

afterPropertiesSet, getEncoders, getRSocketStrategies, handleNoMatch, initReturnValueHandlers, setEncoders, setRSocketStrategies

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

createExceptionMethodResolverFor, getConversionService, getDecoders, getDestination, getDirectLookupMappings, getHandlerPredicate, getMappingComparator, getMappingForMethod, getMatchingMapping, getPathMatcher, getValidator, handleMatch, initArgumentResolvers, initHandlerPredicate, setAutoDetectDisabled, setConversionService, setDecoders, setEmbeddedValueResolver, setHandlerPredicate, setHandlers, setPathMatcher, setValidator

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

detectHandlerMethods, getApplicationContext, getArgumentResolverConfigurer, getBeanName, getDestinationLookup, getHandlerMethods, getReactiveAdapterRegistry, getReturnValueHandlerConfigurer, handleMessage, registerExceptionHandlerAdvice, registerHandlerMethod, setApplicationContext, setArgumentResolverConfigurer, setBeanName, setReactiveAdapterRegistry, setReturnValueHandlerConfigurer

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Field Detail

defaultDataMimeType

@Nullable
private MimeType defaultDataMimeType

Constructor Detail

MessageHandlerAcceptor

public MessageHandlerAcceptor()

Method Detail

setDefaultDataMimeType

public void setDefaultDataMimeType(@Nullable
                                   MimeType defaultDataMimeType)

Configure the default content type to use for data payloads.

By default this is not set. However a server acceptor will use the content type from the ConnectionSetupPayload, so this is typically required for clients but can also be used on servers as a fallback.

Parameters:

defaultDataMimeType - the MimeType to use

accept

public <any> accept(ConnectionSetupPayload setupPayload,
                    RSocket sendingRSocket)

apply

public RSocket apply(RSocket sendingRSocket)

Specified by:

apply in interface java.util.function.Function<RSocket,RSocket>

createRSocket

private MessagingRSocket createRSocket(RSocket rsocket)