X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Fimpl%2FRpcServiceAdapter.java;h=984302f1ea1e703e6cf5f93f5091bcdc7fe1b5cf;hb=220fbf7b619893a063b4e97411f840723e54ddaf;hp=daf502cdffa072bc8df99e6fbb4ac1a78649ae14;hpb=70cd4b01dd47a66c5591e6f8151430bb9c274a09;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/RpcServiceAdapter.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/RpcServiceAdapter.java index daf502cdff..984302f1ea 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/RpcServiceAdapter.java +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/RpcServiceAdapter.java @@ -18,6 +18,7 @@ import java.lang.reflect.Method; import java.lang.reflect.Proxy; import java.util.Collection; import java.util.Map.Entry; +import java.util.concurrent.Future; import org.opendaylight.controller.md.sal.dom.api.DOMRpcException; import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult; import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; @@ -70,8 +71,8 @@ class RpcServiceAdapter implements InvocationHandler { if (result instanceof BindingRpcFutureAware) { return ((BindingRpcFutureAware) result).getBindingFuture(); } else if (result instanceof LegacyDOMRpcResultFutureAdapter) { - CheckedFuture - delegateFuture = ((LegacyDOMRpcResultFutureAdapter)result).delegate(); + Future delegateFuture = + ((LegacyDOMRpcResultFutureAdapter)result).delegate(); if (delegateFuture instanceof BindingRpcFutureAware) { return ((BindingRpcFutureAware) delegateFuture).getBindingFuture(); } @@ -93,11 +94,11 @@ class RpcServiceAdapter implements InvocationHandler { } @Override - public Object invoke(final Object proxyObj, final Method method, final Object[] args) throws Throwable { + public Object invoke(final Object proxyObj, final Method method, final Object[] args) { final RpcInvocationStrategy rpc = rpcNames.get(method); if (rpc != null) { - if (method.getParameterTypes().length == 0) { + if (method.getParameterCount() == 0) { return rpc.invokeEmpty(); } if (args.length != 1) { @@ -115,11 +116,11 @@ class RpcServiceAdapter implements InvocationHandler { private static boolean isObjectMethod(final Method method) { switch (method.getName()) { case "toString": - return method.getReturnType().equals(String.class) && method.getParameterTypes().length == 0; + return method.getReturnType().equals(String.class) && method.getParameterCount() == 0; case "hashCode": - return method.getReturnType().equals(int.class) && method.getParameterTypes().length == 0; + return method.getReturnType().equals(int.class) && method.getParameterCount() == 0; case "equals": - return method.getReturnType().equals(boolean.class) && method.getParameterTypes().length == 1 && method + return method.getReturnType().equals(boolean.class) && method.getParameterCount() == 1 && method .getParameterTypes()[0] == Object.class; default: return false;