X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fblueprint%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fblueprint%2Fext%2FAbstractInvokableServiceMetadata.java;h=30ee9aab5a06fde158272e3ec902cd4e49a33b7b;hp=3bd7c5e4edcf78f123937195810f33a13e22022d;hb=8fbf100a671b513d9ec777c074cffe137773e9bb;hpb=7f7aafb85967dac821a13eaf984bdba499b5afd8 diff --git a/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/AbstractInvokableServiceMetadata.java b/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/AbstractInvokableServiceMetadata.java index 3bd7c5e4ed..30ee9aab5a 100644 --- a/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/AbstractInvokableServiceMetadata.java +++ b/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/AbstractInvokableServiceMetadata.java @@ -14,12 +14,12 @@ import java.util.Collection; import java.util.Set; import java.util.function.Predicate; import org.apache.aries.blueprint.services.ExtendedBlueprintContainer; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcAvailabilityListener; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcIdentifier; -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.mdsal.binding.api.RpcConsumerRegistry; +import org.opendaylight.mdsal.dom.api.DOMRpcAvailabilityListener; +import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier; +import org.opendaylight.mdsal.dom.api.DOMRpcService; import org.opendaylight.mdsal.dom.api.DOMSchemaService; +import org.opendaylight.mdsal.dom.spi.RpcRoutingStrategy; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.binding.RpcService; import org.opendaylight.yangtools.yang.model.api.SchemaContext; @@ -30,7 +30,7 @@ abstract class AbstractInvokableServiceMetadata extends AbstractDependentCompone private final String interfaceName; private ListenerRegistration rpcListenerReg; - private RpcProviderRegistry rpcRegistry; + private RpcConsumerRegistry rpcRegistry; private Class rpcInterface; private Set rpcSchemaPaths; @@ -67,12 +67,12 @@ abstract class AbstractInvokableServiceMetadata extends AbstractDependentCompone @Override protected final void startTracking() { // Request RpcProviderRegistry first ... - retrieveService("RpcProviderRegistry", RpcProviderRegistry.class, this::onRpcRegistry); + retrieveService("RpcConsumerRegistry", RpcConsumerRegistry.class, this::onRpcRegistry); } private void onRpcRegistry(final Object service) { log.debug("{}: Retrieved RpcProviderRegistry {}", logName(), service); - rpcRegistry = (RpcProviderRegistry)service; + rpcRegistry = (RpcConsumerRegistry)service; // Now acquire SchemaService... retrieveService("SchemaService", DOMSchemaService.class, this::onSchemaService);