update deprecated transform and addCallback methods

[groupbasedpolicy.git] / renderers / ofoverlay / src / main / java / org / opendaylight / groupbasedpolicy / renderer / ofoverlay / OfWriter.java

diff --git a/renderers/ofoverlay/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ofoverlay/OfWriter.java b/renderers/ofoverlay/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ofoverlay/OfWriter.java
index 72fff6c0d9394924eff0f896c523532c834f9f75..4eb99dbfe96d4b0471fe5c3390b08b102aa462f4 100755 (executable)
--- a/renderers/ofoverlay/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ofoverlay/OfWriter.java
+++ b/renderers/ofoverlay/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ofoverlay/OfWriter.java
@@ -30,6 +30,8 @@ import com.google.common.collect.Sets;
 import com.google.common.util.concurrent.CheckedFuture;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.MoreExecutors;
+
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
@@ -289,7 +291,7 @@ public class OfWriter {
             public void onSuccess(Void result) {
                 LOG.debug("Flow table {} updated.", tableIid);
             }
-        });
+        }, MoreExecutors.directExecutor());
     }
 
     private void updateGroups(DataBroker dataBroker, final NodeId nodeId)
@@ -367,7 +369,7 @@ public class OfWriter {
             public void onSuccess(Void result) {
                 LOG.debug("Group table on node {} updated.", nodeId);
             }
-        });
+        }, MoreExecutors.directExecutor());
     }
 
 }