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=494118b694a0f9a43c96c5dd747ecf3e3f4ea8f1;hb=526185d061ed50c75890b31a376e9495144b660a;hp=c769ca1ee38509fa3dbebd52948f81735fddf59c;hpb=4b1c94354c0396645effe64388bbefb653e29344;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..494118b694 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,24 +12,26 @@ 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 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) { + override addRpcImplementation(Class type, T implementation) { // TODO Auto-generated method stub val properties = new Hashtable(); @@ -40,4 +42,32 @@ class OsgiProviderContext extends OsgiConsumerContext implements ProviderContext registeredServices.put(type, salReg) return salReg; } + + override addMountRpcImplementation(Class type, InstanceIdentifier mount, T implementation) throws IllegalStateException { + + val properties = new Hashtable(); + properties.salServiceType = SAL_SERVICE_TYPE_PROVIDER + + // Fill requirements + val salReg = broker.registerMountedRpcImplementation(type, implementation, mount, this, properties) + registeredServices.put(type, salReg) + return salReg; + } + + override addRoutedRpcImplementation(Class type, T implementation) throws IllegalStateException { + val properties = new Hashtable(); + properties.salServiceType = SAL_SERVICE_TYPE_PROVIDER + + // Fill requirements + val salReg = broker.registerRoutedRpcImplementation(type, implementation, this, properties) + registeredServices.put(type, salReg) + return salReg; + } + + override registerFunctionality(ProviderFunctionality functionality) { + + } + + override unregisterFunctionality(ProviderFunctionality functionality) { + } }