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 0ca756fdd4..d73c2aa839 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
@@ -136,16 +136,7 @@ public void connectToRedis() {
 
   @Override
   public void connectToRedis(ConnectionSettings connectionSettings) {
-
-    Response connected = null;
-    try {
-      connected = waitForResult(asyncConnectToRedis(connectionSettings));
-      //System.out.printf("Connection %s%n", connected != null ? connected.getConstantResponse() : null);
-    } catch (Exception e) {
-      System.err.println("Connection time out");
-    }
-
-    int a = 5;
+    waitForResult(asyncConnectToRedis(connectionSettings));
   }
 
   private void createChannel() {
@@ -402,7 +393,6 @@ private CompletableFuture<Response> submitNewCommand(RequestType command, List<S
     var commandId = getNextCallbackId();
     //System.out.printf("== %s(%s), callback %d%n", command, String.join(", ", args), commandId);
 
-    //commandId.getRight().
     return CompletableFuture.supplyAsync(() -> {
       RedisRequest request =
           RedisRequest.newBuilder()