From e9c5fbf148d011bd96fa77f7ce6b1ec6dd225a2a Mon Sep 17 00:00:00 2001 From: Igor Artamonov Date: Thu, 28 Jul 2022 23:36:11 -0400 Subject: [PATCH] problem: WS connection doesn't resolve local domain names rel: https://github.com/netty/netty/issues/11142 rel: https://github.com/reactor/reactor-netty/issues/1431 --- .../io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt index f5fa0159..858491aa 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt @@ -34,6 +34,8 @@ import io.netty.buffer.ByteBuf import io.netty.buffer.ByteBufInputStream import io.netty.buffer.Unpooled import io.netty.handler.codec.http.HttpHeaderNames +import io.netty.resolver.DefaultAddressResolverGroup +import io.netty.resolver.DefaultNameResolver import org.reactivestreams.Publisher import org.slf4j.LoggerFactory import org.springframework.util.backoff.BackOff @@ -161,6 +163,7 @@ class WsConnection( log.info("Connecting to WebSocket: $uri") connection?.dispose() connection = HttpClient.create() + .resolver(DefaultAddressResolverGroup.INSTANCE) .doOnDisconnected { log.info("Disconnected from $uri") // mark upstream as UNAVAIL