apply spotless check

Signed-off-by: Kaushal Kumar <[email protected]>

server/src/main/java/org/opensearch/node/Node.java

@@ -1013,16 +1013,22 @@ protected Node(
             // Add the telemetryAwarePlugin components to the existing pluginComponents collection.
             pluginComponents.addAll(telemetryAwarePluginComponents);
 
-            final QueryGroupRequestRejectionOperationListener queryGroupRequestRejectionListener = new QueryGroupRequestRejectionOperationListener(
-                new QueryGroupService(), // We will need to replace this with actual instance of the queryGroupService
-                threadPool
-            );
+            final QueryGroupRequestRejectionOperationListener queryGroupRequestRejectionListener =
+                new QueryGroupRequestRejectionOperationListener(
+                    new QueryGroupService(), // We will need to replace this with actual instance of the queryGroupService
+                    threadPool
+                );
 
             // register all standard SearchRequestOperationsCompositeListenerFactory to the SearchRequestOperationsCompositeListenerFactory
             final SearchRequestOperationsCompositeListenerFactory searchRequestOperationsCompositeListenerFactory =
                 new SearchRequestOperationsCompositeListenerFactory(
                     Stream.concat(
-                        Stream.of(searchRequestStats, searchRequestSlowLog, searchTaskRequestOperationsListener, queryGroupRequestRejectionListener),
+                        Stream.of(
+                            searchRequestStats,
+                            searchRequestSlowLog,
+                            searchTaskRequestOperationsListener,
+                            queryGroupRequestRejectionListener
+                        ),
                         pluginComponents.stream()
                             .filter(p -> p instanceof SearchRequestOperationsListener)
                             .map(p -> (SearchRequestOperationsListener) p)

server/src/main/java/org/opensearch/wlm/QueryGroupService.java

@@ -30,8 +30,8 @@ public void requestFailedFor(final String queryGroupId) {
     public Optional<String> shouldRejectFor(String queryGroupId) {
         if (queryGroupId == null) return Optional.empty();
         // TODO: At this point this is dummy and we need to decide whether to cancel the request based on last
-        //  reported resource usage for the queryGroup. We also need to increment the rejection count here for the
-        //  query group
+        // reported resource usage for the queryGroup. We also need to increment the rejection count here for the
+        // query group
         return Optional.of("Possible reason. ");
     }
 }

server/src/main/java/org/opensearch/wlm/WorkloadManagementTransportInterceptor.java

@@ -50,8 +50,7 @@ public static class RequestHandler<T extends TransportRequest> implements Transp
         TransportRequestHandler<T> actualHandler;
         private final QueryGroupService queryGroupService;
 
-        public RequestHandler(ThreadPool threadPool, TransportRequestHandler<T> actualHandler,
-                              QueryGroupService queryGroupService) {
+        public RequestHandler(ThreadPool threadPool, TransportRequestHandler<T> actualHandler, QueryGroupService queryGroupService) {
             this.threadPool = threadPool;
             this.actualHandler = actualHandler;
             this.queryGroupService = queryGroupService;

server/src/test/java/org/opensearch/wlm/WorkloadManagementTransportRequestHandlerTests.java

@@ -22,7 +22,10 @@
 import java.util.Collections;
 import java.util.Optional;
 
-import static org.mockito.Mockito.*;
+import static org.mockito.Mockito.anyString;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.spy;
+import static org.mockito.Mockito.when;
 
 public class WorkloadManagementTransportRequestHandlerTests extends OpenSearchTestCase {
     private WorkloadManagementTransportInterceptor.RequestHandler<TransportRequest> sut;

server/src/test/java/org/opensearch/wlm/listeners/QueryGroupRequestRejectionOperationListenerTests.java

@@ -25,7 +25,6 @@ public class QueryGroupRequestRejectionOperationListenerTests extends OpenSearch
     QueryGroupService queryGroupService;
     QueryGroupRequestRejectionOperationListener sut;
 
-
     public void setUp() throws Exception {
         super.setUp();
         testThreadPool = new TestThreadPool("RejectionTestThreadPool");