sx/map
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复心跳报文BUG

Browse Source
This commit is contained in:
谷成伟 2024-12-12 09:42:24 +08:00
parent d45fbf3354
commit 7d29d9ba91
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java
View File

@ -34,7 +34,7 @@ public class HeartbeatCommand implements BaseCommand{
for (JsonNode linkNode : links) { for (JsonNode linkNode : links) {
String linkId = linkNode.get("linkId").asText(); String linkId = linkNode.get("linkId").asText();
boolean online = linkNode.get("online").asBoolean(); boolean online = linkNode.get("online").asBoolean();
String key = String.format("link:%d:online", linkId, online); String key = String.format("link:%s:online", linkId);
adminRedisTemplate.set(key, online ? 1 : 0); adminRedisTemplate.set(key, online ? 1 : 0);
adminRedisTemplate.expire(key, HEARTBEAT_TTL); adminRedisTemplate.expire(key, HEARTBEAT_TTL);
} }