diff --git a/src/main/java/com/xydl/cac/iec/RealTimeDataService.java b/src/main/java/com/xydl/cac/iec/RealTimeDataService.java index 3abf30f..5dff2fb 100644 --- a/src/main/java/com/xydl/cac/iec/RealTimeDataService.java +++ b/src/main/java/com/xydl/cac/iec/RealTimeDataService.java @@ -65,9 +65,12 @@ public class RealTimeDataService { iedRepository.save(ied); clientMap.put(ied.getId(), iecClient); } catch (Exception ex) { - log.error("61850订阅异常, ied=" + ied.getName() + ", ip=" + ied.getIp(), ex); + String err = "61850订阅异常, ied=" + ied.getName() + ", ip=" + ied.getIp(); + log.error(err, ex); + throw new BusinessException(err); + } finally { + inDoing = false; } - inDoing = false; } public void stopCollect(Integer iedId) {