Bug 1458 - Migrate to next MD-SAL dataStore API

[openflowplugin.git] / drop-test / src / main / java / org / opendaylight / openflowplugin / droptest / DropTestCommiter.java

diff --git a/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestCommiter.java b/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestCommiter.java
index a45b9b5204f55b3a581e93bdf57d1e16d792816c..b082ef3a4f9809a8cb1e811271c8a4a224ddcf28 100644 (file)
--- a/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestCommiter.java
+++ b/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestCommiter.java
@@ -7,9 +7,10 @@
  */
 package org.opendaylight.openflowplugin.droptest;
 
+import com.google.common.base.Preconditions;
 import java.math.BigInteger;
-
-import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
+import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
@@ -28,8 +29,6 @@ import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.google.common.base.Preconditions;
-
 public class DropTestCommiter extends AbstractDropTest {
     private final static Logger LOG = LoggerFactory.getLogger(DropTestProvider.class);
 
@@ -77,11 +76,11 @@ public class DropTestCommiter extends AbstractDropTest {
                         .build();
 
         final Flow flow = fb.build();
-        final DataModificationTransaction transaction = manager.getDataService().beginTransaction();
+        final ReadWriteTransaction transaction = manager.getDataService().newReadWriteTransaction();
 
         LOG.debug("onPacketReceived - About to write flow {}", flow);
-        transaction.putConfigurationData(flowInstanceId, flow);
-        transaction.commit();
+        transaction.put(LogicalDatastoreType.CONFIGURATION, flowInstanceId, flow);
+        transaction.submit();
         LOG.debug("onPacketReceived - About to write flow commited");
     }
 }