Skip to content

Commit 28fbeb9

Browse files
committed
Removed static Hooks block from RSocketServiceTransport, it's expected clients themselves setup this up if needed on their behalf
1 parent 4523b76 commit 28fbeb9

File tree

1 file changed

+0
-17
lines changed

1 file changed

+0
-17
lines changed

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServiceTransport.java

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -18,30 +18,13 @@
1818
import java.util.StringJoiner;
1919
import java.util.concurrent.ThreadFactory;
2020
import java.util.function.Function;
21-
import org.slf4j.Logger;
22-
import org.slf4j.LoggerFactory;
2321
import reactor.core.publisher.Flux;
24-
import reactor.core.publisher.Hooks;
2522
import reactor.core.publisher.Mono;
2623
import reactor.netty.FutureMono;
27-
import reactor.netty.channel.AbortedException;
2824
import reactor.netty.resources.LoopResources;
2925

3026
public class RSocketServiceTransport implements ServiceTransport {
3127

32-
public static final Logger LOGGER = LoggerFactory.getLogger(RSocketServiceTransport.class);
33-
34-
static {
35-
Hooks.onErrorDropped(
36-
throwable -> {
37-
if (throwable instanceof AbortedException) {
38-
LOGGER.warn("[onErrorDropped] error: {}", throwable.toString());
39-
} else {
40-
LOGGER.error("[onErrorDropped] error:", throwable);
41-
}
42-
});
43-
}
44-
4528
private int numOfWorkers = Runtime.getRuntime().availableProcessors();
4629

4730
private HeadersCodec headersCodec = HeadersCodec.DEFAULT_INSTANCE;

0 commit comments

Comments
 (0)