X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-spi%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fspi%2FForwardingDOMDataReadWriteTransaction.java;h=69e7cc2cd204cc60d03743806f0a6d53dd22183d;hb=e38f06caf5cf5d4b4861315b42fecf7842b4ec05;hp=923bef76f3ef729d77a73729d86f7e5386d0c0a0;hpb=d7ce37f576bcf35aa29665db89cadf854487f338;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-spi/src/main/java/org/opendaylight/controller/md/sal/dom/spi/ForwardingDOMDataReadWriteTransaction.java b/opendaylight/md-sal/sal-dom-spi/src/main/java/org/opendaylight/controller/md/sal/dom/spi/ForwardingDOMDataReadWriteTransaction.java index 923bef76f3..69e7cc2cd2 100644 --- a/opendaylight/md-sal/sal-dom-spi/src/main/java/org/opendaylight/controller/md/sal/dom/spi/ForwardingDOMDataReadWriteTransaction.java +++ b/opendaylight/md-sal/sal-dom-spi/src/main/java/org/opendaylight/controller/md/sal/dom/spi/ForwardingDOMDataReadWriteTransaction.java @@ -10,14 +10,12 @@ package org.opendaylight.controller.md.sal.dom.spi; import com.google.common.base.Optional; import com.google.common.collect.ForwardingObject; import com.google.common.util.concurrent.CheckedFuture; -import com.google.common.util.concurrent.ListenableFuture; -import javax.annotation.Nonnull; -import org.opendaylight.controller.md.sal.common.api.TransactionStatus; +import com.google.common.util.concurrent.FluentFuture; +import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException; -import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException; import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction; -import org.opendaylight.yangtools.yang.common.RpcResult; +import org.opendaylight.mdsal.common.api.CommitInfo; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; @@ -25,17 +23,20 @@ import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; * Utility {@link DOMDataReadWriteTransaction} implementation which forwards all interface * method invocation to a delegate instance. */ -public abstract class ForwardingDOMDataReadWriteTransaction extends ForwardingObject implements DOMDataReadWriteTransaction { +public abstract class ForwardingDOMDataReadWriteTransaction extends ForwardingObject + implements DOMDataReadWriteTransaction { @Override - protected abstract @Nonnull DOMDataReadWriteTransaction delegate(); + protected abstract @NonNull DOMDataReadWriteTransaction delegate(); @Override - public CheckedFuture>, ReadFailedException> read(final LogicalDatastoreType store, final YangInstanceIdentifier path) { + public CheckedFuture>, ReadFailedException> read(final LogicalDatastoreType store, + final YangInstanceIdentifier path) { return delegate().read(store, path); } @Override - public CheckedFuture exists(final LogicalDatastoreType store, final YangInstanceIdentifier path) { + public CheckedFuture exists(final LogicalDatastoreType store, + final YangInstanceIdentifier path) { return delegate().exists(store, path); } @@ -45,12 +46,14 @@ public abstract class ForwardingDOMDataReadWriteTransaction extends ForwardingOb } @Override - public void put(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode data) { + public void put(final LogicalDatastoreType store, final YangInstanceIdentifier path, + final NormalizedNode data) { delegate().put(store, path, data); } @Override - public void merge(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode data) { + public void merge(final LogicalDatastoreType store, final YangInstanceIdentifier path, + final NormalizedNode data) { delegate().merge(store, path, data); } @@ -65,13 +68,7 @@ public abstract class ForwardingDOMDataReadWriteTransaction extends ForwardingOb } @Override - public CheckedFuture submit() { - return delegate().submit(); - } - - @Override - @Deprecated - public ListenableFuture> commit() { + public FluentFuture commit() { return delegate().commit(); } }