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

修改mockMQ

Browse Source
This commit is contained in:
zren25
2025-05-14 11:31:59 +08:00
parent a1aae011ee
commit 06e15f1df1
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -7,6 +7,7 @@ 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;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
@@ -39,7 +40,12 @@ public class TestController {
@ApiOperation(value = "补偿处理消息") @ApiOperation(value = "补偿处理消息")
public ResultMsg<Object> mockMq(@RequestBody String message) { public ResultMsg<Object> mockMq(@RequestBody String message) {
JSONObject messageJson = JSONObject.parseObject(message); JSONObject messageJson = JSONObject.parseObject(message);
rocketMQTemplate.syncSend(messageJson.getString("topic"), messageJson.getString("message")); String tag = messageJson.getString("tag");
String topic = messageJson.getString("topic");
if(StringUtils.isNotEmpty(tag)){
topic = topic+":"+tag;
}
rocketMQTemplate.syncSend(topic, messageJson.getString("message"));
return ResultMsg.ok("ok"); return ResultMsg.ok("ok");
} }