diff --git a/message/message-api/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java b/message/message-api/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
index 8c9cde1..a5d73aa 100644
--- a/message/message-api/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
+++ b/message/message-api/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java
@@ -34,5 +34,5 @@ public class BaseMessage {
      */
     protected Integer retryTimes = 0;
 
-    protected String messageBoy;
+    protected String messageBody;
 }
diff --git a/message/message-boot/src/main/java/com/njcn/message/produce/ProduceController.java b/message/message-boot/src/main/java/com/njcn/message/produce/ProduceController.java
index 748055c..f538515 100644
--- a/message/message-boot/src/main/java/com/njcn/message/produce/ProduceController.java
+++ b/message/message-boot/src/main/java/com/njcn/message/produce/ProduceController.java
@@ -43,7 +43,7 @@ public class ProduceController extends BaseController {
     public HttpResult<Boolean> recall(@RequestParam RecallMessage message){
         String methodDescribe = getMethodDescribe("recall");
         BaseMessage baseMessage = new BaseMessage();
-        baseMessage.setMessageBoy(JSONObject.toJSONString(message));
+        baseMessage.setMessageBody(JSONObject.toJSONString(message));
         recallMessaggeTemplate.sendMember(baseMessage);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
@@ -55,7 +55,7 @@ public class ProduceController extends BaseController {
     public HttpResult<Boolean> askRestartDevice(@RequestBody DeviceRebootMessage message){
         String methodDescribe = getMethodDescribe("recall");
         BaseMessage baseMessage = new BaseMessage();
-        baseMessage.setMessageBoy(JSONObject.toJSONString(message));
+        baseMessage.setMessageBody(JSONObject.toJSONString(message));
         deviceRebootMessageTemplate.sendMember(baseMessage);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
diff --git a/message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java b/message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java
index 193263f..f8f81a4 100644
--- a/message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java
+++ b/message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java
@@ -125,7 +125,7 @@ public class WebSocketServer  {
 //        LineDetailDataVO data = lineFeignClient.getLineDetailData(split[1]).getData();
         askRealDataMessage.setDevSeries(split[2]);
         BaseMessage baseMessage = new BaseMessage();
-        baseMessage.setMessageBoy(JSONObject.toJSONString(askRealDataMessage));
+        baseMessage.setMessageBody(JSONObject.toJSONString(askRealDataMessage));
         // 发送消息到topic1
         askRealDataMessaggeTemplate.sendMember(baseMessage);
         redisUtil.saveByKey("AskRealData:".concat(split[1]),"AskRealData:".concat(split[1]));