A consumer that allows you to communicate to an RSocket route using its fire and forget strategy of execution. The consumer uses the RSocket support from Spring Framework.
You can import RSocketConsumerConfiguration in the application and then inject the following bean.
Function<Flux<Message<?>>, Mono<Void>> rsocketConsumer
You can use rsocketConsumer as a qualifier when injecting.
All configuration properties are prefixed with rsocket.consumer.
For more information on the various options available, please see RsocketConsumerProperties.
See this test suite for learning more about this consumer.
See this README where this consumer is used to create a Spring Cloud Stream based RSocket Sink application.