[CI] Auto commit changes from spotless

Author: elasticsearchmachine

server/src/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java

@@ -681,32 +681,28 @@ private final class AsyncReplicaAction extends AbstractRunnable implements Actio
         public void onResponse(Releasable releasable) {
             assert replica.getActiveOperationsCount() != 0 : "must perform shard operation under a permit";
             try {
-                shardOperationOnReplica(
-                    replicaRequest.getRequest(),
-                    replica,
-                    ActionListener.wrap((replicaResult) -> {
-                        final var response = new ReplicaResponse(replica.getLocalCheckpoint(), replica.getLastSyncedGlobalCheckpoint());
-                        replicaResult.runPostReplicaActions(ActionListener.wrap(r -> {
-                            releasable.close(); // release shard operation lock before responding to caller
-                            if (logger.isTraceEnabled()) {
-                                logger.trace(
-                                    "action [{}] completed on shard [{}] for request [{}]",
-                                    transportReplicaAction,
-                                    replicaRequest.getRequest().shardId(),
-                                    replicaRequest.getRequest()
-                                );
-                            }
-                            setPhase(task, "finished");
-                            onCompletionListener.onResponse(response);
-                        }, e -> {
-                            Releasables.closeWhileHandlingException(releasable); // release shard operation lock before responding to caller
-                            responseWithFailure(e);
-                        }));
+                shardOperationOnReplica(replicaRequest.getRequest(), replica, ActionListener.wrap((replicaResult) -> {
+                    final var response = new ReplicaResponse(replica.getLocalCheckpoint(), replica.getLastSyncedGlobalCheckpoint());
+                    replicaResult.runPostReplicaActions(ActionListener.wrap(r -> {
+                        releasable.close(); // release shard operation lock before responding to caller
+                        if (logger.isTraceEnabled()) {
+                            logger.trace(
+                                "action [{}] completed on shard [{}] for request [{}]",
+                                transportReplicaAction,
+                                replicaRequest.getRequest().shardId(),
+                                replicaRequest.getRequest()
+                            );
+                        }
+                        setPhase(task, "finished");
+                        onCompletionListener.onResponse(response);
                     }, e -> {
                         Releasables.closeWhileHandlingException(releasable); // release shard operation lock before responding to caller
-                        AsyncReplicaAction.this.onFailure(e);
-                    })
-                );
+                        responseWithFailure(e);
+                    }));
+                }, e -> {
+                    Releasables.closeWhileHandlingException(releasable); // release shard operation lock before responding to caller
+                    AsyncReplicaAction.this.onFailure(e);
+                }));
                 // TODO: Evaluate if we still need to catch this exception
             } catch (Exception e) {
                 Releasables.closeWhileHandlingException(releasable); // release shard operation lock before responding to caller