issue opensearch-project#28

mloufra · Jul 20, 2022 · b81a7a1 · b81a7a1
1 parent 9018985
commit b81a7a1
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 95 deletions.
diff --git a/...g/opensearch/discovery/PluginRequest.java → ...iscovery/InitializeExtensionsRequest.java b/...g/opensearch/discovery/PluginRequest.java → ...iscovery/InitializeExtensionsRequest.java
diff --git a/server/src/main/java/org/opensearch/discovery/PluginResponse.java b/server/src/main/java/org/opensearch/discovery/PluginResponse.java
diff --git a/server/src/main/java/org/opensearch/extensions/ExtensionsOrchestrator.java b/server/src/main/java/org/opensearch/extensions/ExtensionsOrchestrator.java
@@ -34,8 +34,8 @@
 import org.opensearch.common.io.stream.StreamInput;
 import org.opensearch.common.settings.Settings;
 import org.opensearch.common.transport.TransportAddress;
-import org.opensearch.discovery.PluginRequest;
-import org.opensearch.discovery.PluginResponse;
+import org.opensearch.discovery.InitializeExtensionsRequest;
+import org.opensearch.discovery.InitializeExtensionsResponse;
 import org.opensearch.extensions.ExtensionsSettings.Extension;
 import org.opensearch.index.IndexModule;
 import org.opensearch.index.IndexService;
@@ -204,15 +204,15 @@ public void extensionsInitialize() {
 
     private void extensionInitialize(DiscoveryNode extensionNode) {
 
-        final TransportResponseHandler<PluginResponse> pluginResponseHandler = new TransportResponseHandler<PluginResponse>() {
+        final TransportResponseHandler<InitializeExtensionsResponse> pluginResponseHandler = new TransportResponseHandler<InitializeExtensionsResponse>() {
 
             @Override
-            public PluginResponse read(StreamInput in) throws IOException {
-                return new PluginResponse(in);
+            public InitializeExtensionsResponse read(StreamInput in) throws IOException {
+                return new InitializeExtensionsResponse(in);
             }
 
             @Override
-            public void handleResponse(PluginResponse response) {
+            public void handleResponse(InitializeExtensionsResponse response) {
                 for (DiscoveryExtension extension : extensionsList) {
                     if (extension.getName().equals(response.getName())) {
                         extensionsInitializedList.add(extension);
@@ -236,7 +236,7 @@ public String executor() {
             transportService.sendRequest(
                 extensionNode,
                 REQUEST_EXTENSION_ACTION_NAME,
-                new PluginRequest(transportService.getLocalNode(), new ArrayList<DiscoveryExtension>(extensionsList)),
+                new InitializeExtensionsRequest(transportService.getLocalNode(), new ArrayList<DiscoveryExtension>(extensionsList)),
                 pluginResponseHandler
             );
         } catch (Exception e) {