andreacavalli/rockserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix client connection

Browse Source
This commit is contained in:
Andrea Cavalli 2024-10-04 01:16:47 +02:00
parent 310f94d473
commit 47c3e31f75
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/it/cavallium/rockserver/core/client/GrpcConnection.java
View File

@ -75,8 +75,16 @@ public class GrpcConnection extends BaseConnection implements RocksDBAPI {
private GrpcConnection(String name, SocketAddress socketAddress, URI address) { private GrpcConnection(String name, SocketAddress socketAddress, URI address) {
super(name); super(name);
var channelBuilder = NettyChannelBuilder NettyChannelBuilder channelBuilder;
.forAddress(socketAddress) if (socketAddress instanceof InetSocketAddress inetSocketAddress) {
channelBuilder = NettyChannelBuilder
.forAddress(inetSocketAddress.getHostString(), inetSocketAddress.getPort());
} else {
channelBuilder = NettyChannelBuilder
.forAddress(socketAddress);
}
channelBuilder
.directExecutor() .directExecutor()
.usePlaintext(); .usePlaintext();
if (socketAddress instanceof DomainSocketAddress _) { if (socketAddress instanceof DomainSocketAddress _) {