diff --git a/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java b/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java index 37ca6a9ee..59ac91c38 100644 --- a/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java +++ b/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java @@ -58,6 +58,7 @@ import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology. import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint; +import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -76,6 +77,7 @@ import static org.opendaylight.controller.md.sal.binding.api.DataObjectModificat public class HuaweiNetconfSpeaker implements DataTreeChangeListener, BindingAwareProvider, AutoCloseable { + private final ListenerRegistration configurationReg; private MountPointService mountService; private DataBroker dataBroker; private static final Logger LOG = LoggerFactory.getLogger(HuaweiNetconfSpeaker.class); @@ -85,7 +87,6 @@ public class HuaweiNetconfSpeaker implements DataTreeChangeListener threads = new ConcurrentHashMap<>(8); - /** * Scheduled Task thread factory */ @@ -94,6 +95,9 @@ public class HuaweiNetconfSpeaker implements DataTreeChangeListener connectPath = InstanceIdentifier.create(ConnectorInfo.class); + final DataTreeIdentifier dataTreeIdentifier = new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION, connectPath); + configurationReg = dataBroker.registerDataTreeChangeListener(dataTreeIdentifier, this); } @@ -164,6 +168,7 @@ public class HuaweiNetconfSpeaker implements DataTreeChangeListener