X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fbroker%2Fimpl%2FPingPongFuture.java;h=fd8f93b67dab930e71ee17ed64570f9639878a9a;hb=4ef15f7a7e3fb5bcaa6a3202d268a5c945e0aa71;hp=611303a41adcfede958c88fb1bb1d8d32304c129;hpb=68fb550b416dddd0a50e0110add0a4ae9b706758;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongFuture.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongFuture.java index 611303a41a..fd8f93b67d 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongFuture.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongFuture.java @@ -12,20 +12,21 @@ import com.google.common.util.concurrent.ListenableFuture; import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException; /** - * A {@link Future} used to report the status of an future {@link java.util.concurrent.Future}. + * A {@link java.util.concurrent.Future} used to report the status of an future + * {@link java.util.concurrent.Future}. */ final class PingPongFuture extends AbstractCheckedFuture { - protected PingPongFuture(final ListenableFuture delegate) { - super(delegate); - } + protected PingPongFuture(final ListenableFuture delegate) { + super(delegate); + } - @Override - protected TransactionCommitFailedException mapException(final Exception e) { - if (e.getCause() instanceof TransactionCommitFailedException){ - return (TransactionCommitFailedException) e.getCause(); - } else { - return new TransactionCommitFailedException(e.getMessage(), e.getCause(), null); + @Override + protected TransactionCommitFailedException mapException(final Exception exception) { + if (exception.getCause() instanceof TransactionCommitFailedException) { + return (TransactionCommitFailedException) exception.getCause(); + } else { + return new TransactionCommitFailedException(exception.getMessage(), exception.getCause()); + } } - } }