Add Logger for RpcRegistryImpl

Change-Id: I6ef0133f0128fbf5cfb9ed9f0e738af0bda3a852
Signed-off-by: Marek Gradzki <mgradzki@cisco.com>

diff --git a/infra/rpc/impl/pom.xml b/infra/rpc/impl/pom.xml
index 395b5f0..30d544d 100644 (file)
--- a/infra/rpc/impl/pom.xml
+++ b/infra/rpc/impl/pom.xml
@@ -48,6 +48,10 @@
             <artifactId>future-converter-java8-guava</artifactId>
             <version>0.3.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
 
         <!-- tests -->
         <dependency>
@@ -65,10 +69,5 @@
             <artifactId>mockito-core</artifactId>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-api</artifactId>
-            <scope>test</scope>
-        </dependency>
     </dependencies>
 </project>

diff --git a/infra/rpc/impl/src/main/java/io/fd/honeycomb/rpc/RpcRegistryBuilder.java b/infra/rpc/impl/src/main/java/io/fd/honeycomb/rpc/RpcRegistryBuilder.java
index 0b96be0..ca6441e 100644 (file)
--- a/infra/rpc/impl/src/main/java/io/fd/honeycomb/rpc/RpcRegistryBuilder.java
+++ b/infra/rpc/impl/src/main/java/io/fd/honeycomb/rpc/RpcRegistryBuilder.java
@@ -25,6 +25,8 @@ import javax.annotation.Nullable;
 import org.opendaylight.controller.md.sal.dom.api.DOMRpcImplementationNotAvailableException;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.model.api.SchemaPath;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public final class RpcRegistryBuilder {
 
@@ -40,6 +42,7 @@ public final class RpcRegistryBuilder {
 
 
     private static final class RpcRegistryImpl implements RpcRegistry {
+        private static final Logger LOG = LoggerFactory.getLogger(RpcRegistryImpl.class);
         private final Map<SchemaPath, RpcService> services;
 
         private RpcRegistryImpl(@Nonnull final Map<SchemaPath, RpcService> services) {
@@ -51,11 +54,13 @@ public final class RpcRegistryBuilder {
         public CompletionStage invoke(@Nonnull final SchemaPath schemaPath, @Nullable final DataObject request) {
             final RpcService rpcService = services.get(schemaPath);
             if (rpcService == null) {
+                LOG.error("Missing Rpc service for schemaPath: {}", schemaPath);
                 final CompletableFuture<DataObject> result = new CompletableFuture<>();
                 result.completeExceptionally(
                     new DOMRpcImplementationNotAvailableException("Service not found: %s", schemaPath));
                 return result;
             }
+            LOG.debug("Delegating rpcRequest: {} to rpcService: {}", request, rpcService);
             return rpcService.invoke(request);
 
         }