import org.opendaylight.controller.md.sal.dom.api.DOMRpcService;
import org.opendaylight.controller.md.sal.dom.broker.spi.rpc.RpcRoutingStrategy;
import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
-import org.opendaylight.controller.sal.core.api.model.SchemaService;
+import org.opendaylight.mdsal.dom.api.DOMSchemaService;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.binding.RpcService;
import org.opendaylight.yangtools.yang.model.api.SchemaContext;
final Class<?> interfaceClass;
try {
interfaceClass = container().getBundleContext().getBundle().loadClass(interfaceName);
- } catch (Exception e) {
+ } catch (final Exception e) {
throw new ComponentDefinitionException(String.format("%s: Error obtaining interface class %s",
logName(), interfaceName), e);
}
rpcRegistry = (RpcProviderRegistry)service;
// Now acquire SchemaService...
- retrieveService("SchemaService", SchemaService.class, this::onSchemaService);
+ retrieveService("SchemaService", DOMSchemaService.class, this::onSchemaService);
}
private void onSchemaService(final Object service) {
log.debug("{}: Retrieved SchemaService {}", logName(), service);
// Now get the SchemaContext and trigger RPC resolution
- retrievedSchemaContext(((SchemaService)service).getGlobalContext());
+ retrievedSchemaContext(((DOMSchemaService)service).getGlobalContext());
}
private void retrievedSchemaContext(final SchemaContext schemaContext) {
final Collection<SchemaPath> schemaPaths = RpcUtil.decomposeRpcService(rpcInterface, schemaContext,
rpcFilter());
if (schemaPaths.isEmpty()) {
- log.warn("{}: interface {} has no accptable entries, assuming it is satisfied");
+ log.warn("{}: interface {} has no accptable entries, assuming it is satisfied", logName(), rpcInterface);
setSatisfied();
return;
}
log.debug("{}: create returning service {}", logName(), rpcService);
return rpcService;
- } catch (RuntimeException e) {
+ } catch (final RuntimeException e) {
throw new ComponentDefinitionException("Error getting RPC service for " + interfaceName, e);
}
}