learning switch shifted to new data broker API

[openflowplugin.git] / samples / learning-switch / src / main / java / org / opendaylight / openflowplugin / learningswitch / WakeupOnNode.java

diff --git a/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/WakeupOnNode.java b/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/WakeupOnNode.java
index 3ce3dd0bc368332e2f72968455b2773cb10f6a89..7a860ffed779b09ed5df28bf7b4b7f6578f93690 100644 (file)
--- a/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/WakeupOnNode.java
+++ b/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/WakeupOnNode.java
@@ -10,9 +10,8 @@ package org.opendaylight.openflowplugin.learningswitch;
 
 import java.util.Map;
 import java.util.Map.Entry;
-
-import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent;
-import org.opendaylight.controller.sal.binding.api.data.DataChangeListener;
+import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
+import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
@@ -20,27 +19,28 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * 
+ *
  */
 public class WakeupOnNode implements DataChangeListener {
-    
+
     private static final Logger LOG = LoggerFactory
             .getLogger(WakeupOnNode.class);
-    
+
     private LearningSwitchHandler learningSwitchHandler;
 
     @Override
-    public void onDataChanged(DataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
+    public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
         Short requiredTableId = 0;
-        
+
         // TODO add flow
-        Map<InstanceIdentifier<?>, DataObject> updated = change.getUpdatedOperationalData();
+
+        Map<InstanceIdentifier<?>, DataObject> updated = change.getUpdatedData();
         for (Entry<InstanceIdentifier<?>, DataObject> updateItem : updated.entrySet()) {
             DataObject table = updateItem.getValue();
             if (table instanceof Table) {
                 Table tableSure = (Table) table;
                 LOG.trace("table: {}", table);
-                
+
                 if (requiredTableId.equals(tableSure.getId())) {
                     @SuppressWarnings("unchecked")
                     InstanceIdentifier<Table> tablePath = (InstanceIdentifier<Table>) updateItem.getKey();
@@ -49,7 +49,7 @@ public class WakeupOnNode implements DataChangeListener {
             }
         }
     }
-    
+
     /**
      * @param learningSwitchHandler the learningSwitchHandler to set
      */
@@ -57,4 +57,5 @@ public class WakeupOnNode implements DataChangeListener {
             LearningSwitchHandler learningSwitchHandler) {
         this.learningSwitchHandler = learningSwitchHandler;
     }
+
 }