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.
The RSocketConsumerConfiguration auto-configuration provides the following beans:
Function<Flux<Message<?>>, Mono<Void>> rsocketFunctionsConsumer
You can use rsocketFunctionsConsumer as a qualifier when injecting.
The returned Mono has to be subscribed.
Or Consumer<Flux<Message<?>>> rsocketConsumer can be used instead which just does a Mono.block() before returning.
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.