Topology manager - implementation of NodeChangeListener

[openflowplugin.git] / applications / topology-manager / src / main / java / org / opendaylight / openflowplugin / applications / topology / manager / LinkChangeListenerImpl.java

diff --git a/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/LinkChangeListenerImpl.java b/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/LinkChangeListenerImpl.java
index f6be043bef5a9c20112e8a73dd8cdc7b94c2a4e1..ef0f4d9fdb0eb262d961fc2592a0a20f628ccea8 100644 (file)
--- a/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/LinkChangeListenerImpl.java
+++ b/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/LinkChangeListenerImpl.java
@@ -11,7 +11,6 @@ import java.util.Map;
 import java.util.Set;
 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
 import org.opendaylight.yangtools.yang.binding.DataObject;
-
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
@@ -25,8 +24,9 @@ import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 
 public class LinkChangeListenerImpl implements DataChangeListener, AutoCloseable {
     private final ListenerRegistration<DataChangeListener> dataChangeListenerRegistration;
+    private OperationProcessor operationProcessor;
 
-    public LinkChangeListenerImpl(final DataBroker dataBroker) {
+    public LinkChangeListenerImpl(final DataBroker dataBroker, final OperationProcessor operationProcessor) {
         dataChangeListenerRegistration = dataBroker.registerDataChangeListener(
                 LogicalDatastoreType.OPERATIONAL,
                 InstanceIdentifier.builder(Nodes.class)
@@ -35,6 +35,7 @@ public class LinkChangeListenerImpl implements DataChangeListener, AutoCloseable
                         .augmentation(FlowCapableNodeConnector.class)
                         .build(),
                 this, AsyncDataBroker.DataChangeScope.BASE);
+        this.operationProcessor = operationProcessor;
     }
 
     @Override