X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=dom%2Fmdsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fdom%2Fbroker%2FShardedDOMReadTransactionAdapter.java;h=e04a0828ef28cd61a4548d7e3dab2a5140e6b3c1;hb=f2910f31928b7f29c7e3593065ba35460052c38f;hp=c0f7ae187576697d3908afd9ca7645c1f6ad64ba;hpb=b798df97a01fdd0ac78d1d57a24ebadc7b38bed3;p=mdsal.git diff --git a/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/ShardedDOMReadTransactionAdapter.java b/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/ShardedDOMReadTransactionAdapter.java index c0f7ae1875..e04a0828ef 100644 --- a/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/ShardedDOMReadTransactionAdapter.java +++ b/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/ShardedDOMReadTransactionAdapter.java @@ -95,7 +95,7 @@ public class ShardedDOMReadTransactionAdapter implements DOMDataTreeReadTransact } @Override - public void onFailure(final Throwable t) { + public void onFailure(final Throwable throwable) { reg.close(); } }); @@ -109,7 +109,7 @@ public class ShardedDOMReadTransactionAdapter implements DOMDataTreeReadTransact checkRunning(); LOG.debug("{}: Invoking exists at {}:{}", txIdentifier, store, path); final Function>, Boolean> transform = - optionalNode -> optionalNode.isPresent() ? Boolean.TRUE : Boolean.FALSE; + optionalNode -> optionalNode.isPresent() ? Boolean.TRUE : Boolean.FALSE; final ListenableFuture existsResult = Futures.transform(read(store, path), transform); return Futures.makeChecked(existsResult, ReadFailedException.MAPPER); } @@ -122,7 +122,7 @@ public class ShardedDOMReadTransactionAdapter implements DOMDataTreeReadTransact private final SettableFuture>> readResultFuture; - public ReadShardedListener(final SettableFuture>> future) { + ReadShardedListener(final SettableFuture>> future) { this.readResultFuture = Preconditions.checkNotNull(future); } @@ -151,8 +151,7 @@ public class ShardedDOMReadTransactionAdapter implements DOMDataTreeReadTransact // We chain all exceptions and return aggregated one readResultFuture.setException(new DOMDataTreeListeningException("Aggregated DOMDataTreeListening exception", - causes.stream().reduce((e1, e2) -> - { + causes.stream().reduce((e1, e2) -> { e1.addSuppressed(e2); return e1; }).get()));