opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/osgi/ProxyFactory.xtend

   1 package org.opendaylight.controller.sal.dom.broker.osgi
   2
   3 import org.opendaylight.controller.sal.core.api.BrokerService
   4 import org.osgi.framework.ServiceReference
   5 import org.opendaylight.controller.sal.core.api.data.DataBrokerService
   6 import org.opendaylight.controller.sal.core.api.data.DataProviderService
   7 import org.opendaylight.controller.sal.core.api.notify.NotificationPublishService
   8 import org.opendaylight.controller.sal.core.api.notify.NotificationService
   9 import org.opendaylight.controller.sal.core.api.model.SchemaService
  10 import org.opendaylight.controller.sal.core.api.mount.MountProvisionService
  11 import org.opendaylight.controller.sal.core.api.RpcProvisionRegistry
  12
  13 class ProxyFactory {
  14
  15     static def <T extends BrokerService> T createProxy(ServiceReference<T> serviceRef, T service) {
  16         return createProxyImpl(serviceRef, service) as T;
  17     }
  18
  19     private static def dispatch createProxyImpl(ServiceReference<?> ref, DataBrokerService service) {
  20         new DataBrokerServiceProxy(ref as ServiceReference<DataBrokerService>, service);
  21     }
  22
  23     private static def dispatch createProxyImpl(ServiceReference<?> ref, DataProviderService service) {
  24         new DataProviderServiceProxy(ref as ServiceReference<DataProviderService>, service);
  25     }
  26
  27     private static def dispatch createProxyImpl(ServiceReference<?> ref, NotificationPublishService service) {
  28         new NotificationPublishServiceProxy(ref as ServiceReference<NotificationPublishService>, service);
  29     }
  30
  31     private static def dispatch createProxyImpl(ServiceReference<?> ref, NotificationService service) {
  32         new NotificationServiceProxy(ref as ServiceReference<NotificationService>, service);
  33     }
  34
  35     private static def dispatch createProxyImpl(ServiceReference<?> ref, MountProvisionService service) {
  36         new MountProviderServiceProxy(ref as ServiceReference<MountProvisionService>, service);
  37     }
  38
  39
  40     private static def dispatch createProxyImpl(ServiceReference<?> ref, SchemaService service) {
  41         new SchemaServiceProxy(ref as ServiceReference<SchemaService>, service);
  42     }
  43
  44     private static def dispatch createProxyImpl(ServiceReference<?> ref, RpcProvisionRegistry service) {
  45         new RpcProvisionRegistryProxy(ref as ServiceReference<RpcProvisionRegistry>, service);
  46     }
  47
  48     private static def dispatch createProxyImpl(ServiceReference<?> reference, BrokerService service) {
  49         throw new IllegalArgumentException("Not supported class");
  50     }
  51
  52 }