implements NetworkTransactionService.commit()

[transportpce.git] / common / src / main / java / org / opendaylight / transportpce / common / network / NetworkTransactionImpl.java

diff --git a/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java b/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java
index 232e4d906d482fd37cea5cb490a76c78b5cf6891..beb2a2f05c83baf94e4a706c14b413e3d160c72d 100644 (file)
--- a/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java
+++ b/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java
@@ -8,13 +8,15 @@
 
 package org.opendaylight.transportpce.common.network;
 
+import com.google.common.util.concurrent.FluentFuture;
 import com.google.common.util.concurrent.ListenableFuture;
+import org.eclipse.jdt.annotation.NonNull;
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.mdsal.common.api.CommitInfo;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 
 
-
 public class NetworkTransactionImpl implements NetworkTransactionService {
 
     RequestProcessor requestProcessor;
@@ -53,6 +55,10 @@ public class NetworkTransactionImpl implements NetworkTransactionService {
         return requestProcessor.submit();
     }
 
+    public FluentFuture<? extends @NonNull CommitInfo> commit() {
+        return requestProcessor.commit();
+    }
+
     @Override
     public void close() {