diff --git a/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java b/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java index 45db3a1b..b2ecf27b 100644 --- a/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java +++ b/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java @@ -46,11 +46,11 @@ public class HeartbeatCommand implements BaseCommand{ for (JsonNode linkNode : links) { String linkId = linkNode.get("linkId").asText(); boolean online = linkNode.get("online").asBoolean(); - JsonNode modbusNode = linkNode.get("modbus"); - if (modbusNode != null){ - boolean modbus = modbusNode.asBoolean(); + JsonNode realNode = linkNode.get("real"); + if (realNode != null){ + boolean real = realNode.asBoolean(); String key = String.format("link:%s:modbus", linkId); - ops.set(key, modbus, HEARTBEAT_TTL, TimeUnit.SECONDS); + ops.set(key, real, HEARTBEAT_TTL, TimeUnit.SECONDS); } JsonNode ftpNode = linkNode.get("ftp"); if (ftpNode != null){