admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
lxu75
2025-04-17 18:24:04 +08:00
parent 53557fabee
commit bfd5565b0f
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
View File

@@ -1,6 +1,7 @@
package com.volvo.ai.analytic.center.controller; package com.volvo.ai.analytic.center.controller;
import com.alibaba.fastjson.JSONObject;
import com.volvo.common.core.util.ResultMsg; import com.volvo.common.core.util.ResultMsg;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
@@ -28,8 +29,9 @@ public class TestController {
@PostMapping("/mockMq") @PostMapping("/mockMq")
@ApiOperation(value = "补偿处理消息") @ApiOperation(value = "补偿处理消息")
public ResultMsg<Object> mockMq(@RequestBody String topic,@RequestBody String message) { public ResultMsg<Object> mockMq(@RequestBody String message) {
rocketMQTemplate.syncSend(topic, message); JSONObject messageJson = JSONObject.parseObject(message);
rocketMQTemplate.syncSend(messageJson.getString("topic"), messageJson.getString("message"));
return ResultMsg.ok("ok"); return ResultMsg.ok("ok");
} }