rsocket-java: Handling network errors in ClientServerInputMultiplexer

We get these network failures logged as errors and they are not “errors” in some cases… If the other side stops, which the client still tries to communicate with it, you will get such errors. It would be great if there would be some callback support here and there, where clients can decide what is worth logging as an error.

2020-05-04 09:49:39,725 [RSocket-epoll-2] ERROR io.rsocket.FrameLogger - Error receiving frame: 
io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

About this issue

Original URL
State: closed
Created 4 years ago
Comments: 30 (14 by maintainers)

Most upvoted comments

@rstoyanchev Perfectly agree with the purpose of logging what’s on the wire for RSocket … however, if there is an error, one could expect to be notified on the doOnError? It should not be the role of the “logger” class … I would think?

Mono<RSocket> mono = RSocketFactory.connect()
                       .......
                mono.doOnError(Throwable.class, throwable -> handleFailure(throwable, false))

adrian-tarau on May 6, 2020