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

Use direct executor in client

Browse Source
This commit is contained in:
Andrea Cavalli 2024-10-02 18:09:14 +02:00
parent 60474f2a75
commit b7172db2f9
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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