修改mock接口

2025-04-10 18:37:59 +08:00
parent 79a1880cba
commit f5fb1f4fb6
1 changed files with 2 additions and 2 deletions
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
@@ -28,8 +28,8 @@ public class TestController {

    @PostMapping("/mockMq")
    @ApiOperation(value = "补偿处理消息")
-    public ResultMsg<Object> mockMq(@RequestBody String message) {
-        rocketMQTemplate.syncSend("COMMUNITY_POST_TO_AI_TOPIC", message);
+    public ResultMsg<Object> mockMq(@RequestBody String topic,@RequestBody String message) {
+        rocketMQTemplate.syncSend(topic, message);
        return ResultMsg.ok("ok");
    }