mirror of
https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git
synced 2026-01-25 07:46:40 +08:00
完善
This commit is contained in:
@@ -81,6 +81,21 @@ public class DataCollectorController {
|
||||
}
|
||||
|
||||
|
||||
@PostMapping("/getXml")
|
||||
public Object getXml(@RequestBody GetXmlRequest request) {
|
||||
return this.service.getXml(request);
|
||||
}
|
||||
|
||||
|
||||
@PostMapping("/getVersion")
|
||||
public Object getVersion(@RequestBody GetXmlRequest request) {
|
||||
return this.service.getVersion(request);
|
||||
}
|
||||
|
||||
|
||||
@PostMapping("/restart")
|
||||
public Object restart(@RequestBody GetXmlRequest request) {
|
||||
return this.service.restart(request);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -0,0 +1,3 @@
|
||||
package cn.lihongjie.coal.dataCollector.dto;
|
||||
|
||||
public record GetXmlRequest(String appKey){}
|
||||
@@ -101,6 +101,33 @@ public class DataCollectorService
|
||||
|
||||
}
|
||||
|
||||
|
||||
public Object getXml(GetXmlRequest request) {
|
||||
|
||||
return rabbitTemplate.convertSendAndReceive(
|
||||
"dataCollector." + request.appKey(), Map.of("action", "getXML")
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
|
||||
public Object getVersion(GetXmlRequest request) {
|
||||
|
||||
return rabbitTemplate.convertSendAndReceive(
|
||||
"dataCollector." + request.appKey(), Map.of("action", "getVersion")
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
|
||||
public Object restart(GetXmlRequest request) {
|
||||
|
||||
return rabbitTemplate.convertSendAndReceive(
|
||||
"dataCollector." + request.appKey(), Map.of("action", "restart")
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
public Object sendMsg(String id, String action, Object data, Map<String, String> headers) {
|
||||
|
||||
DataCollectorEntity collector = get(id);
|
||||
|
||||
Reference in New Issue
Block a user