前置日志联调
This commit is contained in:
@@ -85,7 +85,7 @@ public class FrontHeartBeatConsumer extends EnhanceConsumerMessageHandler<FrontH
|
||||
protected void handleMessage(FrontHeartBeatDTO message) {
|
||||
//将心跳状态存到redis失效时间为30s,如果持续有心跳则进程在线反之,redis找不到则不在线
|
||||
if(Objects.equals(message.getFronttype(), FrontTypeEnum.STAT.getCode())){
|
||||
redisUtil.saveByKeyWithExpire(message.getNodeId().concat(":").concat(message.getProcessNum()+""),message.getStatus(),30L);
|
||||
redisUtil.saveByKeyWithExpire(message.getNodeId().concat(":").concat(message.getProcessNo()+""),message.getStatus(),30L);
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user