Java: Update transaction handling and IT

java/client/src/main/java/glide/api/RedisClient.java

@@ -61,7 +61,7 @@ public CompletableFuture<Object> customCommand(@NonNull String[] args) {
 
     @Override
     public CompletableFuture<Object[]> exec(@NonNull Transaction transaction) {
-        return commandManager.submitNewCommand(transaction, this::handleArrayOrNullResponse);
+        return commandManager.submitNewTransaction(transaction, this::handleArrayOrNullResponse);
     }
 
     @Override

java/client/src/main/java/glide/api/RedisClusterClient.java

@@ -88,14 +88,14 @@ protected ClusterValue<Object> handleCustomCommandResponse(Route route, Response
 
     @Override
     public CompletableFuture<Object[]> exec(@NonNull ClusterTransaction transaction) {
-        return commandManager.submitNewCommand(
+        return commandManager.submitNewTransaction(
                 transaction, Optional.empty(), this::handleArrayOrNullResponse);
     }
 
     @Override
     public CompletableFuture<Object[]> exec(
             @NonNull ClusterTransaction transaction, @NonNull SingleNodeRoute route) {
-        return commandManager.submitNewCommand(
+        return commandManager.submitNewTransaction(
                 transaction, Optional.of(route), this::handleArrayOrNullResponse);
     }
 

java/client/src/main/java/glide/managers/CommandManager.java

@@ -82,7 +82,7 @@ public <T> CompletableFuture<T> submitNewCommand(
      * @param responseHandler The handler for the response object
      * @return A result promise of type T
      */
-    public <T> CompletableFuture<T> submitNewCommand(
+    public <T> CompletableFuture<T> submitNewTransaction(
             Transaction transaction, RedisExceptionCheckedFunction<Response, T> responseHandler) {
 
         RedisRequest.Builder command = prepareRedisRequest(transaction);
@@ -109,14 +109,14 @@ public <T> CompletableFuture<T> submitScript(
     }
 
     /**
-     * Build a Transaction and send.
+     * Build a Cluster Transaction and send.
      *
      * @param transaction Redis Transaction request with multiple commands
      * @param route Transaction routing parameters
      * @param responseHandler The handler for the response object
      * @return A result promise of type T
      */
-    public <T> CompletableFuture<T> submitNewCommand(
+    public <T> CompletableFuture<T> submitNewTransaction(
             ClusterTransaction transaction,
             Optional<Route> route,
             RedisExceptionCheckedFunction<Response, T> responseHandler) {

java/client/src/test/java/glide/api/RedisClientTest.java

@@ -232,7 +232,7 @@ public void exec() {
         testResponse.complete(value);
 
         // match on protobuf request
-        when(commandManager.<Object[]>submitNewCommand(eq(transaction), any()))
+        when(commandManager.<Object[]>submitNewTransaction(eq(transaction), any()))
                 .thenReturn(testResponse);
 
         // exercise

java/client/src/test/java/glide/api/RedisClusterClientTest.java

@@ -171,7 +171,8 @@ public void exec_without_routing() {
         testResponse.complete(value);
 
         // match on protobuf request
-        when(commandManager.<Object[]>submitNewCommand(eq(transaction), eq(Optional.empty()), any()))
+        when(commandManager.<Object[]>submitNewTransaction(
+                        eq(transaction), eq(Optional.empty()), any()))
                 .thenReturn(testResponse);
 
         // exercise
@@ -195,7 +196,8 @@ public void exec_with_routing() {
         testResponse.complete(value);
 
         // match on protobuf request
-        when(commandManager.<Object[]>submitNewCommand(eq(transaction), eq(Optional.of(route)), any()))
+        when(commandManager.<Object[]>submitNewTransaction(
+                        eq(transaction), eq(Optional.of(route)), any()))
                 .thenReturn(testResponse);
 
         // exercise

java/client/src/test/java/glide/managers/CommandManagerTest.java

@@ -288,7 +288,7 @@ public void submitNewCommand_with_Transaction_sends_protobuf_request() {
                 ArgumentCaptor.forClass(RedisRequest.Builder.class);
 
         // exercise
-        service.submitNewCommand(trans, r -> null);
+        service.submitNewTransaction(trans, r -> null);
 
         // verify
         verify(channelHandler).write(captor.capture(), anyBoolean());
@@ -328,7 +328,7 @@ public void submitNewCommand_with_ClusterTransaction_with_route_sends_protobuf_r
         ArgumentCaptor<RedisRequest.Builder> captor =
                 ArgumentCaptor.forClass(RedisRequest.Builder.class);
 
-        service.submitNewCommand(trans, Optional.of(routeType), r -> null);
+        service.submitNewTransaction(trans, Optional.of(routeType), r -> null);
         verify(channelHandler).write(captor.capture(), anyBoolean());
         var requestBuilder = captor.getValue();