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.

Since:
5.2.1
Author:
Artem Bilan