vldpyatkov commented on code in PR #5221:
URL: https://github.com/apache/ignite-3/pull/5221#discussion_r1987300098
##########
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java:
##########
@@ -178,20 +180,24 @@ public <T extends Message> CompletableFuture<Message>
invokeWithDone(final PeerI
public <T extends Message> CompletableFuture<Message> invokeWithDone(final
PeerId peerId, final Message request,
final RpcResponseClosure<T> done, final int timeoutMs,
final Executor rpcExecutor) {
- return invokeWithDone(peerId, request, null, done, timeoutMs,
rpcExecutor);
+ return invokeWithDone(peerId, request, null, done, timeoutMs,
rpcExecutor, this.rpcClient);
}
public <T extends Message> CompletableFuture<Message> invokeWithDone(final
PeerId peerId, final Message request,
final InvokeContext ctx,
final RpcResponseClosure<T> done, final int timeoutMs) {
- return invokeWithDone(peerId, request, ctx, done, timeoutMs,
this.rpcExecutor);
+ return invokeWithDone(peerId, request, ctx, done, timeoutMs,
this.rpcExecutor, this.rpcClient);
}
- public <T extends Message> CompletableFuture<Message> invokeWithDone(final
PeerId peerId, final Message request,
- final InvokeContext ctx,
- final RpcResponseClosure<T> done, final int timeoutMs,
- final Executor rpcExecutor) {
- final RpcClient rc = this.rpcClient;
+ public <T extends Message> CompletableFuture<Message> invokeWithDone(
+ PeerId peerId,
Review Comment:
I applied formatting that is used in our entire project.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
