增加日志
This commit is contained in:
@@ -36,6 +36,7 @@ public class TestController {
|
|||||||
@PostMapping("/mockMq")
|
@PostMapping("/mockMq")
|
||||||
@ApiOperation(value = "补偿处理消息")
|
@ApiOperation(value = "补偿处理消息")
|
||||||
public ResultMsg<Object> mockMq(@RequestBody String message) {
|
public ResultMsg<Object> mockMq(@RequestBody String message) {
|
||||||
|
log.info("mockMq message:{}", message);
|
||||||
JSONObject messageJson = JSONObject.parseObject(message);
|
JSONObject messageJson = JSONObject.parseObject(message);
|
||||||
rocketMQTemplate.syncSend(messageJson.getString("topic"), messageJson.getString("message"));
|
rocketMQTemplate.syncSend(messageJson.getString("topic"), messageJson.getString("message"));
|
||||||
return ResultMsg.ok("ok");
|
return ResultMsg.ok("ok");
|
||||||
|
|||||||
Reference in New Issue
Block a user