Merge pull request #423 from xujianhai666/feat-stopall
[ISSUE #379] Restful add eliminate, stopAll interface.
diff --git a/rocketmq-connect/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java b/rocketmq-connect/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java
index 261aeb6..e6ea7b7 100644
--- a/rocketmq-connect/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java
+++ b/rocketmq-connect/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java
@@ -46,6 +46,7 @@
app.get("/connectors/:connectorName/config", this::handleQueryConnectorConfig);
app.get("/connectors/:connectorName/status", this::handleQueryConnectorStatus);
app.get("/connectors/:connectorName/stop", this::handleStopConnector);
+ app.get("/connectors/stopAll", this::handleStopAllConnector);
app.get("/getClusterInfo", this::getClusterInfo);
app.get("/getConfigInfo", this::getConfigInfo);
app.get("/getAllocatedInfo", this::getAllocatedInfo);
@@ -138,4 +139,17 @@
context.result("failed");
}
}
+
+ private void handleStopAllConnector(Context context) {
+ try {
+ Set<WorkerConnector> workerConnectors = connectController.getWorker().getWorkingConnectors();
+ for (WorkerConnector connector : workerConnectors) {
+ connectController.getConfigManagementService().removeConnectorConfig(connector.getConnectorName());
+ }
+ context.result("success");
+ } catch (Exception e) {
+ context.result("failed");
+ }
+ }
+
}
