import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RoutedRpcRegistration
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration
+import org.opendaylight.controller.sal.binding.api.data.DataProviderService
+import org.opendaylight.controller.sal.binding.api.data.DataBrokerService
class BindingAwareBrokerImpl implements BindingAwareBroker {
private static val log = LoggerFactory.getLogger(BindingAwareBrokerImpl)
private var RuntimeCodeGenerator generator;
private Map<Class<? extends RpcService>, RpcProxyContext> managedProxies = new HashMap();
private var NotificationBrokerImpl notifyBroker
+ private var DataBrokerImpl dataBroker
private var ServiceRegistration<NotificationProviderService> notifyBrokerRegistration
@Property
// Initialization of notificationBroker
notifyBroker = new NotificationBrokerImpl(null);
+ dataBroker = new DataBrokerImpl();
val brokerProperties = newProperties();
notifyBrokerRegistration = brokerBundleContext.registerService(NotificationProviderService, notifyBroker,
brokerProperties)
brokerBundleContext.registerService(NotificationService, notifyBroker, brokerProperties)
+ brokerBundleContext.registerService(DataProviderService,dataBroker,brokerProperties)
+ brokerBundleContext.registerService(DataBrokerService,dataBroker,brokerProperties)
+
}
def initGenerator() {
return new RpcServiceRegistrationImpl<T>(type, service, osgiReg);
}
- def <T extends RpcService> RpcRegistration<T> registerMountedRpcImplementation(Class<T> tyoe, T service, InstanceIdentifier identifier,
+ def <T extends RpcService> RpcRegistration<T> registerMountedRpcImplementation(Class<T> tyoe, T service, InstanceIdentifier<?> identifier,
OsgiProviderContext context, Hashtable<String, String> properties) {
throw new UnsupportedOperationException("TODO: auto-generated method stub")
}