diff --git a/java/benchmarks/src/main/java/javababushka/benchmarks/clients/babushka/JniNettyClient.java b/java/benchmarks/src/main/java/javababushka/benchmarks/clients/babushka/JniNettyClient.java index c99eaf5fa0..82bfb48a74 100644 --- a/java/benchmarks/src/main/java/javababushka/benchmarks/clients/babushka/JniNettyClient.java +++ b/java/benchmarks/src/main/java/javababushka/benchmarks/clients/babushka/JniNettyClient.java @@ -47,7 +47,6 @@ import javababushka.client.RedisClient; import org.apache.commons.lang3.tuple.Pair; -import java.net.SocketAddress; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; @@ -271,7 +270,7 @@ public String get(String key) { // TODO support non-strings } - private synchronized Pair> getNextCallbackId() { + private synchronized Pair> getNextCallback() { var future = new CompletableFuture(); responses.add(future); return Pair.of(responses.size() - 1, future); @@ -390,7 +389,7 @@ public Future asyncConnectToRedis(ConnectionSettings connectionSetting } private CompletableFuture submitNewCommand(RequestType command, List args) { - var commandId = getNextCallbackId(); + var commandId = getNextCallback(); //System.out.printf("== %s(%s), callback %d%n", command, String.join(", ", args), commandId); return CompletableFuture.supplyAsync(() -> {