rsocket-client-raw.java

@Component
public record RClient() {

    @EventListener(ApplicationReadyEvent.class)
    public void ready() {
        var source = RSocketConnector.create()
                .reconnect(Retry.backoff(50, Duration.ofMillis(500)))//
                .connect(TcpClientTransport.create("localhost", 7766));

        RSocketClient.from(source).fireAndForget(Mono.just(DefaultPayload.create("Reactive Spring!"))).block();
    }
}