binding/mdsal-binding-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/dom/adapter/BindingDOMRpcServiceAdapter.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.mdsal.binding.dom.adapter;
   9
  10 import static com.google.common.base.Preconditions.checkArgument;
  11 import static java.util.Objects.requireNonNull;
  12
  13 import com.google.common.annotations.VisibleForTesting;
  14 import com.google.common.collect.ClassToInstanceMap;
  15 import com.google.common.collect.ImmutableSet;
  16 import java.util.Set;
  17 import org.opendaylight.mdsal.binding.api.RpcService;
  18 import org.opendaylight.mdsal.binding.dom.adapter.BindingDOMAdapterBuilder.Factory;
  19 import org.opendaylight.mdsal.binding.spec.reflect.BindingReflections;
  20 import org.opendaylight.mdsal.dom.api.DOMRpcService;
  21 import org.opendaylight.mdsal.dom.api.DOMService;
  22 import org.opendaylight.yangtools.yang.binding.Rpc;
  23
  24 @VisibleForTesting
  25 public final class BindingDOMRpcServiceAdapter
  26         extends AbstractBindingLoadingAdapter<DOMRpcService, Class<?>, RpcAdapter> implements RpcService {
  27     static final Factory<RpcService> BUILDER_FACTORY = Builder::new;
  28
  29     public BindingDOMRpcServiceAdapter(final AdapterContext adapterContext, final DOMRpcService domService) {
  30         super(adapterContext, domService);
  31     }
  32
  33     @Override
  34     public <T extends Rpc<?, ?>> T getRpc(final Class<T> rpcInterface) {
  35         return rpcInterface.cast(getAdapter(requireNonNull(rpcInterface)).facade());
  36     }
  37
  38     @Override
  39     RpcAdapter loadAdapter(final Class<?> key) {
  40         checkArgument(BindingReflections.isBindingClass(key));
  41         checkArgument(key.isInterface(), "Supplied RPC service type must be interface.");
  42         if (Rpc.class.isAssignableFrom(key)) {
  43             return new RpcAdapter(adapterContext(), getDelegate(), key.asSubclass(Rpc.class));
  44         } else {
  45             throw new IllegalStateException("Unhandled key " + key);
  46         }
  47     }
  48
  49     private static final class Builder extends BindingDOMAdapterBuilder<RpcService> {
  50         Builder(final AdapterContext adapterContext) {
  51             super(adapterContext);
  52         }
  53
  54         @Override
  55         public Set<? extends Class<? extends DOMService>> getRequiredDelegates() {
  56             return ImmutableSet.of(DOMRpcService.class);
  57         }
  58
  59         @Override
  60         protected RpcService createInstance(final ClassToInstanceMap<DOMService> delegates) {
  61             return new BindingDOMRpcServiceAdapter(adapterContext(), delegates.getInstance(DOMRpcService.class));
  62         }
  63     }
  64 }