diff --git a/message/message-boot/src/main/java/com/njcn/message/produce/ScheduledProducer.java b/message/message-boot/src/main/java/com/njcn/message/produce/ScheduledProducer.java index ccef87c..8435f9f 100644 --- a/message/message-boot/src/main/java/com/njcn/message/produce/ScheduledProducer.java +++ b/message/message-boot/src/main/java/com/njcn/message/produce/ScheduledProducer.java @@ -38,7 +38,7 @@ public class ScheduledProducer { FrontHeartBeatDTO frontHeartBeatDTO = new FrontHeartBeatDTO(); frontHeartBeatDTO.setNodeId("7d67349a44a9a4e1d02417f31e310a28"); frontHeartBeatDTO.setStatus("1"); - frontHeartBeatDTO.setProcessNum(1); + frontHeartBeatDTO.setProcessNo(1); // 6. 每30秒执行一次消息发送 scheduler.scheduleAtFixedRate(() -> { try {