X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fbinding%2Fimpl%2FOsgiProviderContext.xtend;h=d1ec35157f5770080b75fbe794637c220c0a2d43;hb=d1ab4c3ea79bcd74e02aa9334bc660cb7fc6d037;hp=c769ca1ee38509fa3dbebd52948f81735fddf59c;hpb=6b64494fd8e4654a298312afb4b8e6e827b75d5d;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/OsgiProviderContext.xtend b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/OsgiProviderContext.xtend index c769ca1ee3..d1ec35157f 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/OsgiProviderContext.xtend +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/OsgiProviderContext.xtend @@ -12,32 +12,43 @@ import java.util.Hashtable; import java.util.Map; import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; -import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcServiceRegistration; import org.opendaylight.yangtools.yang.binding.RpcService; import org.osgi.framework.BundleContext; import static org.opendaylight.controller.sal.binding.impl.osgi.Constants.*; import static extension org.opendaylight.controller.sal.binding.impl.osgi.PropertiesUtils.*; +import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration +import org.opendaylight.yangtools.yang.binding.InstanceIdentifier +import org.opendaylight.controller.sal.binding.api.BindingAwareProvider.ProviderFunctionality +import static com.google.common.base.Preconditions.* class OsgiProviderContext extends OsgiConsumerContext implements ProviderContext { @Property - val Map, RpcServiceRegistrationImpl> registeredServices + val Map, RpcRegistration> registeredServices new(BundleContext ctx, BindingAwareBrokerImpl broker) { super(ctx, broker); _registeredServices = new HashMap(); } - override def RpcServiceRegistration addRpcImplementation(Class type, T implementation) { - - // TODO Auto-generated method stub - val properties = new Hashtable(); - properties.salServiceType = SAL_SERVICE_TYPE_PROVIDER + override addRpcImplementation(Class type, T implementation) { + val salReg = broker.addRpcImplementation(type, implementation) + registeredServices.put(type, salReg) + return salReg; + } - // Fill requirements - val salReg = broker.registerRpcImplementation(type, implementation, this, properties) + override addRoutedRpcImplementation(Class type, T implementation) throws IllegalStateException { + val salReg = broker.addRoutedRpcImplementation(type, implementation) registeredServices.put(type, salReg) return salReg; } + + override registerFunctionality(ProviderFunctionality functionality) { + // NOOP for now + } + + override unregisterFunctionality(ProviderFunctionality functionality) { + // NOOP for now + } }