Change action listener request (#141)

* Add ActionListener onFailure to ExtensionsRunner Signed-off-by: Ryan Bogan <[email protected]> * Addressed PR Comments Signed-off-by: Ryan Bogan <[email protected]> * Addressed PR Comments Signed-off-by: Ryan Bogan <[email protected]> * Addressed PR Comments Signed-off-by: Ryan Bogan <[email protected]> * Removed test failure Signed-off-by: Ryan Bogan <[email protected]> * Changed Action Listener onFailure request class name to match OpenSearch repo Signed-off-by: Ryan Bogan <[email protected]> * Fixed minor error Signed-off-by: Ryan Bogan <[email protected]> Signed-off-by: Ryan Bogan <[email protected]>
opensearch-project · Sep 26, 2022 · d7b873c · d7b873c
1 parent 30d6373
commit d7b873c
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/main/java/org/opensearch/sdk/ExtensionsRunner.java b/src/main/java/org/opensearch/sdk/ExtensionsRunner.java
@@ -31,6 +31,7 @@
 import org.opensearch.extensions.ExtensionBooleanResponse;
 import org.opensearch.discovery.InitializeExtensionsRequest;
 import org.opensearch.discovery.InitializeExtensionsResponse;
+import org.opensearch.extensions.ExtensionActionListenerOnFailureRequest;
 import org.opensearch.extensions.DiscoveryExtension;
 import org.opensearch.extensions.EnvironmentSettingsRequest;
 import org.opensearch.extensions.AddSettingsUpdateConsumerRequest;
@@ -554,10 +555,7 @@ public void sendActionListenerOnFailureRequest(TransportService transportService
             transportService.sendRequest(
                 opensearchNode,
                 ExtensionsOrchestrator.REQUEST_EXTENSION_ACTION_LISTENER_ON_FAILURE,
-                new ExtensionRequest(
-                    ExtensionsOrchestrator.RequestType.REQUEST_EXTENSION_ACTION_LISTENER_ON_FAILURE,
-                    failureException.toString()
-                ),
+                new ExtensionActionListenerOnFailureRequest(failureException.toString()),
                 listenerHandler
             );
         } catch (Exception e) {