X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FRemoteDOMRpcFuture.java;h=046b204121aa084de311f7f63f39f47d91909df2;hp=46c7676b533815de59dfdd354f14151448883e35;hb=12fcdfe39aa26dcba7fd3bb4d4c68e3d02e65c51;hpb=9ddc65e1ddae50f691566cd9382707679436c055 diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteDOMRpcFuture.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteDOMRpcFuture.java index 46c7676b53..046b204121 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteDOMRpcFuture.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteDOMRpcFuture.java @@ -25,14 +25,15 @@ import org.slf4j.LoggerFactory; import scala.concurrent.ExecutionContext; import scala.concurrent.Future; -class RemoteDOMRpcFuture extends AbstractFuture implements CheckedFuture { +final class RemoteDOMRpcFuture extends AbstractFuture + implements CheckedFuture { private static final Logger LOG = LoggerFactory.getLogger(RemoteDOMRpcFuture.class); private final QName rpcName; private RemoteDOMRpcFuture(final QName rpcName) { - this.rpcName = Preconditions.checkNotNull(rpcName,"rpcName"); + this.rpcName = Preconditions.checkNotNull(rpcName, "rpcName"); } public static RemoteDOMRpcFuture create(final QName rpcName) { @@ -70,7 +71,7 @@ class RemoteDOMRpcFuture extends AbstractFuture implements Checked } } - private DOMRpcException mapException(final ExecutionException ex) { + private static DOMRpcException mapException(final ExecutionException ex) { final Throwable cause = ex.getCause(); if (cause instanceof DOMRpcException) { return (DOMRpcException) cause; @@ -81,7 +82,7 @@ class RemoteDOMRpcFuture extends AbstractFuture implements Checked private final class FutureUpdater extends OnComplete { @Override - public void onComplete(final Throwable error, final Object reply) throws Throwable { + public void onComplete(final Throwable error, final Object reply) { if (error != null) { RemoteDOMRpcFuture.this.failNow(error); } else if (reply instanceof RpcResponse) {