This commit is contained in:
Andrea Cavalli 2024-09-13 20:23:01 +02:00
parent 044c4e04bd
commit d29b4e45fe

View File

@ -88,7 +88,7 @@ public class GrpcConnection extends BaseConnection implements RocksDBAPI {
public GrpcConnection(String name, HostAndPort address) { public GrpcConnection(String name, HostAndPort address) {
super(name); super(name);
var channelBuilder = ManagedChannelBuilder var channelBuilder = ManagedChannelBuilder
.forTarget(address.toString()) .forAddress(address.host(), address.port())
.usePlaintext(); .usePlaintext();
this.channel = channelBuilder.build(); this.channel = channelBuilder.build();
this.blockingStub = RocksDBServiceGrpc.newBlockingStub(channel); this.blockingStub = RocksDBServiceGrpc.newBlockingStub(channel);