X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=binding%2Fmdsal-binding-dom-adapter%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fbinding%2Fdom%2Fadapter%2FRpcServiceAdapter.java;h=1938faf875ae2c86c8e30b6b3f0eaf3278139d43;hb=fe28fd1721be937add6bd220c686ed023c6f0529;hp=f7a69b59560f7f7308a0311c8782c5ebf713e7de;hpb=d90adcf214a8f17ae5de22cf8964cbb2a9963972;p=mdsal.git diff --git a/binding/mdsal-binding-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/dom/adapter/RpcServiceAdapter.java b/binding/mdsal-binding-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/dom/adapter/RpcServiceAdapter.java index f7a69b5956..1938faf875 100644 --- a/binding/mdsal-binding-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/dom/adapter/RpcServiceAdapter.java +++ b/binding/mdsal-binding-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/dom/adapter/RpcServiceAdapter.java @@ -7,6 +7,9 @@ */ package org.opendaylight.mdsal.binding.dom.adapter; +import static java.util.Objects.requireNonNull; +import static org.opendaylight.mdsal.binding.dom.adapter.StaticConfiguration.ENABLE_CODEC_SHORTCUT; + import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; import com.google.common.util.concurrent.Futures; @@ -47,9 +50,9 @@ class RpcServiceAdapter implements InvocationHandler { RpcServiceAdapter(final Class type, final BindingToNormalizedNodeCodec codec, final DOMRpcService domService) { - this.type = Preconditions.checkNotNull(type); - this.codec = Preconditions.checkNotNull(codec); - this.delegate = Preconditions.checkNotNull(domService); + this.type = requireNonNull(type); + this.codec = requireNonNull(codec); + this.delegate = requireNonNull(domService); final ImmutableMap.Builder rpcBuilder = ImmutableMap.builder(); for (final Entry rpc : codec.getRpcMethodToSchema(type).entrySet()) { rpcBuilder.put(rpc.getKey(), createStrategy(rpc.getKey(), rpc.getValue())); @@ -133,7 +136,7 @@ class RpcServiceAdapter implements InvocationHandler { ListenableFuture> invoke0(final SchemaPath schemaPath, final ContainerNode input) { final ListenableFuture result = delegate.invokeRpc(schemaPath, input); - if (result instanceof BindingRpcFutureAware) { + if (ENABLE_CODEC_SHORTCUT && result instanceof BindingRpcFutureAware) { return ((BindingRpcFutureAware) result).getBindingFuture(); }