update deprecated transform and addCallback methods
[groupbasedpolicy.git] / renderers / iovisor / src / main / java / org / opendaylight / groupbasedpolicy / renderer / iovisor / sf / ClassifierDefinitionListener.java
index 433e162fab025535f5b95202306f28ea253a7f07..f92a591edd99917b557aed31072c73c5328a9c36 100755 (executable)
@@ -32,6 +32,7 @@ import org.slf4j.LoggerFactory;
 
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.MoreExecutors;
 
 public class ClassifierDefinitionListener extends DataTreeChangeHandler<ClassifierDefinition> {
 
@@ -46,7 +47,8 @@ public class ClassifierDefinitionListener extends DataTreeChangeHandler<Classifi
         .build();
 
     public ClassifierDefinitionListener(DataBroker dataBroker) {
-        super(dataBroker, new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION,
+        super(dataBroker);
+        registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION,
                 InstanceIdentifier.builder(SubjectFeatureDefinitions.class).child(ClassifierDefinition.class).build()));
     }
 
@@ -96,7 +98,7 @@ public class ClassifierDefinitionListener extends DataTreeChangeHandler<Classifi
 
             wTx.delete(LogicalDatastoreType.OPERATIONAL,
                     CAPABILITIES_IID.child(SupportedClassifierDefinition.class, supportedClassifierDefinitionKey));
-            Futures.addCallback(wTx.submit(), logDebugResult(supportedClassifierDefinitionKey, DELETED));
+            Futures.addCallback(wTx.submit(), logDebugResult(supportedClassifierDefinitionKey, DELETED), MoreExecutors.directExecutor());
         }
     }
 
@@ -112,7 +114,7 @@ public class ClassifierDefinitionListener extends DataTreeChangeHandler<Classifi
             wTx.put(LogicalDatastoreType.OPERATIONAL,
                     CAPABILITIES_IID.child(SupportedClassifierDefinition.class, supportedClassifierDefinition.getKey()),
                     supportedClassifierDefinition, true);
-            Futures.addCallback(wTx.submit(), logDebugResult(supportedClassifierDefinition.getKey(), PUT));
+            Futures.addCallback(wTx.submit(), logDebugResult(supportedClassifierDefinition.getKey(), PUT), MoreExecutors.directExecutor());
         }
     }
 }