diff --git 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
index c558670..a17b206 100644
--- 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");
     }