@ -66,6 +66,7 @@ public class IecClient implements ClientEventListener {
public void disconnect() {
try {
clientAssociation.disconnect();
clientAssociation = null;
} catch (Exception ignore) {
}
@ -71,10 +71,9 @@ public class RealTimeDataService {
iedRepository.save(ied);
clientMap.put(ied.getId(), iecClient);
} catch (Exception ex) {
ied.setStart(Constants.FALSE);
String err = "61850订阅异常, ied=" + ied.getName() + ", ip=" + ied.getIp() + ", port=" + ied.getPort();
log.error(err, ex);
this.stopCollect(iedId);
throw new BusinessException(err);
} finally {
inDoing = false;