Provide RpcConsumerRegistry to LightyServices

Due to MDSAL RpcService to Rpc<?,?> migration, RpcService
instance is extracted from RpcConsumerRegistry. We want to
have RpcConsumerRegistry available in LightyServices to easily
access it anywhere.

Fixes #1775

Signed-off-by: tobias.pobocik <tobias.pobocik@pantheon.tech>
Signed-off-by: Ivan Hrasko <ivan.hrasko@pantheon.tech>

Author: Tobianas

lighty-core/lighty-controller/src/main/java/io/lighty/core/controller/api/LightyServices.java

@@ -23,6 +23,7 @@
 import org.opendaylight.mdsal.binding.api.MountPointService;
 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
 import org.opendaylight.mdsal.binding.api.NotificationService;
+import org.opendaylight.mdsal.binding.api.RpcConsumerRegistry;
 import org.opendaylight.mdsal.binding.api.RpcProviderService;
 import org.opendaylight.mdsal.binding.dom.adapter.ConstantAdapterContext;
 import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeFactory;
@@ -131,4 +132,6 @@ public interface LightyServices extends LightyModuleRegistryService {
 
     ActionService getActionService();
 
+    RpcConsumerRegistry getRpcConsumerRegistry();
+
 }

lighty-core/lighty-controller/src/main/java/io/lighty/core/controller/impl/LightyControllerImpl.java

@@ -79,6 +79,7 @@
 import org.opendaylight.mdsal.binding.api.MountPointService;
 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
 import org.opendaylight.mdsal.binding.api.NotificationService;
+import org.opendaylight.mdsal.binding.api.RpcConsumerRegistry;
 import org.opendaylight.mdsal.binding.api.RpcProviderService;
 import org.opendaylight.mdsal.binding.dom.adapter.BindingAdapterFactory;
 import org.opendaylight.mdsal.binding.dom.adapter.BindingDOMMountPointServiceAdapter;
@@ -196,6 +197,7 @@ public class LightyControllerImpl extends AbstractLightyModule implements Lighty
     private AkkaManagement akkaManagement;
     private Optional<ClusteringHandler> clusteringHandler;
     private Optional<InitialConfigData> initialConfigData;
+    private RpcConsumerRegistry rpcConsumerRegistry;
 
 
     public LightyControllerImpl(final ExecutorService executorService, final Config actorSystemConfig,
@@ -306,6 +308,7 @@ protected boolean initProcedure() {
         this.actionProviderService = this.bindingAdapterFactory.createActionProviderService(
                 this.domActionProviderService);
         this.actionService = bindingAdapterFactory.createActionService(this.domActionService);
+        rpcConsumerRegistry = bindingAdapterFactory.createRpcConsumerRegistry(domRpcRouter.getRpcService());
 
         this.rpcProviderService = new BindingDOMRpcProviderServiceAdapter(this.codec,
                 this.domRpcRouter.getRpcProviderService());
@@ -664,6 +667,11 @@ public ActionProviderService getActionProviderService() {
         return actionProviderService;
     }
 
+    @Override
+    public RpcConsumerRegistry getRpcConsumerRegistry() {
+        return rpcConsumerRegistry;
+    }
+
     @Override
     public ActionService getActionService() {
         return actionService;