StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

problem: WS connection doesn't resolve local domain names

Browse Source 
rel: https://github.com/netty/netty/issues/11142
rel: https://github.com/reactor/reactor-netty/issues/1431
This commit is contained in:
Igor Artamonov
2022-07-28 23:36:11 -04:00
parent d65a217535
commit e9c5fbf148
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt
View File

@@ -34,6 +34,8 @@ import io.netty.buffer.ByteBuf
import io.netty.buffer.ByteBufInputStream import io.netty.buffer.ByteBufInputStream
import io.netty.buffer.Unpooled import io.netty.buffer.Unpooled
import io.netty.handler.codec.http.HttpHeaderNames import io.netty.handler.codec.http.HttpHeaderNames
import io.netty.resolver.DefaultAddressResolverGroup
import io.netty.resolver.DefaultNameResolver
import org.reactivestreams.Publisher import org.reactivestreams.Publisher
import org.slf4j.LoggerFactory import org.slf4j.LoggerFactory
import org.springframework.util.backoff.BackOff import org.springframework.util.backoff.BackOff
@@ -161,6 +163,7 @@ class WsConnection(
log.info("Connecting to WebSocket: $uri") log.info("Connecting to WebSocket: $uri")
connection?.dispose() connection?.dispose()
connection = HttpClient.create() connection = HttpClient.create()
.resolver(DefaultAddressResolverGroup.INSTANCE)
.doOnDisconnected { .doOnDisconnected {
log.info("Disconnected from $uri") log.info("Disconnected from $uri")
// mark upstream as UNAVAIL // mark upstream as UNAVAIL