diff --git a/src/main/java/com/xydl/cac/iec/RealTimeDataService.java b/src/main/java/com/xydl/cac/iec/RealTimeDataService.java index 31b4898..54a5715 100644 --- a/src/main/java/com/xydl/cac/iec/RealTimeDataService.java +++ b/src/main/java/com/xydl/cac/iec/RealTimeDataService.java @@ -83,6 +83,9 @@ public class RealTimeDataService { public void stopCollect(Integer iedId) { IecClient iecClient = clientMap.get(iedId); if (iecClient != null) { + iecClient.keep = false; + iecClient.realTimeDataService = null; + iecClient.webSocketServer = null; iecClient.disableReporting(); iecClient.disconnect(); clientMap.remove(iedId); @@ -92,7 +95,7 @@ public class RealTimeDataService { IcdIed ied = optional.get(); ied.setStart(Constants.FALSE); iedRepository.save(ied); - log.info("61850停止订阅, ied=" + ied.getName() + ", ip=" + ied.getIp()); + log.info("61850停止订阅, ied=" + ied.getName() + ", ip=" + ied.getIp() + ", port=" + ied.getPort()); } }