code refactoring

Signed-off-by: Kuanysh Aimurzinov <[email protected]>
opensearch-project · Jun 21, 2023 · adfeca8 · adfeca8
1 parent b335b84
commit adfeca8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 12 deletions.
diff --git a/server/src/main/java/org/opensearch/common/settings/AbstractScopedSettings.java b/server/src/main/java/org/opensearch/common/settings/AbstractScopedSettings.java
@@ -249,7 +249,7 @@ public synchronized <T> void addSettingsUpdateConsumer(Setting<T> setting, Consu
             throw new SettingsException("Setting is not registered for key [" + setting.getKey() + "]");
         }
         addSettingsUpdater(setting.newUpdater(consumer, logger, validator));
-        }
+    }
 
     /**
      * Adds a settings consumer that is only executed if any setting in the supplied list of settings is changed. In that case all the

diff --git a/server/src/main/java/org/opensearch/extensions/AddSettingsUpdateConsumerRequestHandler.java b/server/src/main/java/org/opensearch/extensions/AddSettingsUpdateConsumerRequestHandler.java
@@ -87,17 +87,16 @@ TransportResponse handleAddSettingsUpdateConsumerRequest(AddSettingsUpdateConsum
 
                 // Register setting update consumer with callback method to extension
                 if (setting.hasIndexScope()) {
-                    clusterService.getClusterSettings()
-                        .addSettingsUpdateConsumer(settingForUpdateConsumer, (data) -> {
-                            logger.debug("Sending extension request type: " + updateSettingsRequestType);
-                            UpdateSettingsResponseHandler updateSettingsResponseHandler = new UpdateSettingsResponseHandler();
-                            transportService.sendRequest(
-                                extensionNode,
-                                updateSettingsRequestType,
-                                new UpdateSettingsRequest(settingType, setting, data),
-                                updateSettingsResponseHandler
-                            );
-                        });
+                    clusterService.getClusterSettings().addSettingsUpdateConsumer(settingForUpdateConsumer, (data) -> {
+                        logger.debug("Sending extension request type: " + updateSettingsRequestType);
+                        UpdateSettingsResponseHandler updateSettingsResponseHandler = new UpdateSettingsResponseHandler();
+                        transportService.sendRequest(
+                            extensionNode,
+                            updateSettingsRequestType,
+                            new UpdateSettingsRequest(settingType, setting, data),
+                            updateSettingsResponseHandler
+                        );
+                    });
                 }
                 if (setting.hasNodeScope()) {
                     clusterService.getClusterSettings()