X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Fimpl%2FBindingDOMTransactionChainAdapter.java;h=4dc55d2e148c6d7f5c1c7dce1295b05f0ba17379;hb=6dbf8f82cfa9fe8c35e4085213a55cb887cc3aee;hp=1a0787eb19d1dc9abbf8827ede516f7cb585fe66;hpb=709744dd78576e3cb3ab2b4f483c3fcc14a8ad00;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingDOMTransactionChainAdapter.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingDOMTransactionChainAdapter.java index 1a0787eb19..4dc55d2e14 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingDOMTransactionChainAdapter.java +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingDOMTransactionChainAdapter.java @@ -53,15 +53,14 @@ final class BindingDOMTransactionChainAdapter implements BindingTransactionChain @Override public ReadOnlyTransaction newReadOnlyTransaction() { - DOMDataReadOnlyTransaction delegateTx = delegate.newReadOnlyTransaction(); - ReadOnlyTransaction bindingTx = new BindingDOMReadTransactionAdapter(delegateTx, codec); - return bindingTx; + final DOMDataReadOnlyTransaction delegateTx = delegate.newReadOnlyTransaction(); + return new BindingDOMReadTransactionAdapter(delegateTx, codec); } @Override public ReadWriteTransaction newReadWriteTransaction() { - DOMDataReadWriteTransaction delegateTx = delegate.newReadWriteTransaction(); - ReadWriteTransaction bindingTx = new BindingDOMReadWriteTransactionAdapter(delegateTx, codec) { + final DOMDataReadWriteTransaction delegateTx = delegate.newReadWriteTransaction(); + return new BindingDOMReadWriteTransactionAdapter(delegateTx, codec) { @Override public CheckedFuture submit() { @@ -69,33 +68,31 @@ final class BindingDOMTransactionChainAdapter implements BindingTransactionChain } }; - return bindingTx; } @Override public WriteTransaction newWriteOnlyTransaction() { final DOMDataWriteTransaction delegateTx = delegate.newWriteOnlyTransaction(); - WriteTransaction bindingTx = new BindingDOMWriteTransactionAdapter(delegateTx, codec) { + return new BindingDOMWriteTransactionAdapter(delegateTx, codec) { @Override public CheckedFuture submit() { return listenForFailure(this,super.submit()); - }; + } }; - return bindingTx; } private CheckedFuture listenForFailure( - final WriteTransaction tx, CheckedFuture future) { + final WriteTransaction tx, final CheckedFuture future) { Futures.addCallback(future, new FutureCallback() { @Override - public void onFailure(Throwable t) { + public void onFailure(final Throwable t) { failTransactionChain(tx,t); } @Override - public void onSuccess(Void result) { + public void onSuccess(final Void result) { // Intentionally NOOP } }); @@ -103,7 +100,7 @@ final class BindingDOMTransactionChainAdapter implements BindingTransactionChain return future; } - private void failTransactionChain(WriteTransaction tx, Throwable t) { + private void failTransactionChain(final WriteTransaction tx, final Throwable t) { /* * We asume correct state change for underlaying transaction *