*/
package org.opendaylight.lispflowmapping.implementation.mdsal;
-import org.opendaylight.controller.md.sal.binding.api.ClusteredDataTreeChangeListener;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
+import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.yangtools.concepts.Registration;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
* The superclass for the different MD-SAL data change event listeners.
*
*/
-public abstract class AbstractDataListener<T extends DataObject> implements ClusteredDataTreeChangeListener<T> {
+public abstract class AbstractDataListener<T extends DataObject> implements DataTreeChangeListener<T> {
private DataBroker broker;
private InstanceIdentifier<T> path;
- private ListenerRegistration<ClusteredDataTreeChangeListener<T>> registration;
-
- public void registerDataChangeListener() {
- final DataTreeIdentifier<T> dataTreeIdentifier = new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION,
- path);
-
- registration = broker.registerDataTreeChangeListener(dataTreeIdentifier, this);
+ private Registration configRegistration;
+ private Registration operRegistration;
+
+ void registerDataChangeListener() {
+ configRegistration = broker.registerTreeChangeListener(
+ DataTreeIdentifier.of(LogicalDatastoreType.CONFIGURATION, path), this);
+ operRegistration = broker.registerTreeChangeListener(
+ DataTreeIdentifier.of(LogicalDatastoreType.OPERATIONAL, path), this);
}
public void closeDataChangeListener() {
- registration.close();
+ configRegistration.close();
+ operRegistration.close();
}
- public void setBroker(DataBroker broker) {
+ void setBroker(DataBroker broker) {
this.broker = broker;
}
void setPath(InstanceIdentifier<T> path) {
this.path = path;
}
-
}