修改mockMQ
This commit is contained in:
@@ -40,8 +40,8 @@ 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);
|
||||||
String tag = messageJson.getString("tag");
|
|
||||||
String topic = messageJson.getString("topic");
|
String topic = messageJson.getString("topic");
|
||||||
|
String tag = messageJson.getString("tag");
|
||||||
if(StringUtils.isNotEmpty(tag)){
|
if(StringUtils.isNotEmpty(tag)){
|
||||||
topic = topic+":"+tag;
|
topic = topic+":"+tag;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user