Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改错误拼写

Browse Source
This commit is contained in:
hzj
2025-02-13 15:38:01 +08:00
parent d7dbec9da9
commit 685ded0945
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
message/message-api/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
View File

@@ -34,5 +34,5 @@ public class BaseMessage {
*/ */
protected Integer retryTimes = 0; protected Integer retryTimes = 0;
protected String messageBoy; protected String messageBody;
} }

4
message/message-boot/src/main/java/com/njcn/message/produce/ProduceController.java
View File

@@ -43,7 +43,7 @@ public class ProduceController extends BaseController {
public HttpResult<Boolean> recall(@RequestParam RecallMessage message){ public HttpResult<Boolean> recall(@RequestParam RecallMessage message){
String methodDescribe = getMethodDescribe("recall"); String methodDescribe = getMethodDescribe("recall");
BaseMessage baseMessage = new BaseMessage(); BaseMessage baseMessage = new BaseMessage();
baseMessage.setMessageBoy(JSONObject.toJSONString(message)); baseMessage.setMessageBody(JSONObject.toJSONString(message));
recallMessaggeTemplate.sendMember(baseMessage); recallMessaggeTemplate.sendMember(baseMessage);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
} }
@@ -55,7 +55,7 @@ public class ProduceController extends BaseController {
public HttpResult<Boolean> askRestartDevice(@RequestBody DeviceRebootMessage message){ public HttpResult<Boolean> askRestartDevice(@RequestBody DeviceRebootMessage message){
String methodDescribe = getMethodDescribe("recall"); String methodDescribe = getMethodDescribe("recall");
BaseMessage baseMessage = new BaseMessage(); BaseMessage baseMessage = new BaseMessage();
baseMessage.setMessageBoy(JSONObject.toJSONString(message)); baseMessage.setMessageBody(JSONObject.toJSONString(message));
deviceRebootMessageTemplate.sendMember(baseMessage); deviceRebootMessageTemplate.sendMember(baseMessage);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
} }

2
message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java
View File

@@ -125,7 +125,7 @@ public class WebSocketServer {
// LineDetailDataVO data = lineFeignClient.getLineDetailData(split[1]).getData(); // LineDetailDataVO data = lineFeignClient.getLineDetailData(split[1]).getData();
askRealDataMessage.setDevSeries(split[2]); askRealDataMessage.setDevSeries(split[2]);
BaseMessage baseMessage = new BaseMessage(); BaseMessage baseMessage = new BaseMessage();
baseMessage.setMessageBoy(JSONObject.toJSONString(askRealDataMessage)); baseMessage.setMessageBody(JSONObject.toJSONString(askRealDataMessage));
// 发送消息到topic1 // 发送消息到topic1
askRealDataMessaggeTemplate.sendMember(baseMessage); askRealDataMessaggeTemplate.sendMember(baseMessage);
redisUtil.saveByKey("AskRealData:".concat(split[1]),"AskRealData:".concat(split[1])); redisUtil.saveByKey("AskRealData:".concat(split[1]),"AskRealData:".concat(split[1]));