Class 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.

Artem Bilan