exchanging new version yang models on firmware upgrade

[oam/tr069-adapter.git] / acs / requestprocessor / src / main / java / org / commscope / tr069adapter / acs / requestprocessor / handler / DeviceRPCRequestHandler.java

diff --git a/acs/requestprocessor/src/main/java/org/commscope/tr069adapter/acs/requestprocessor/handler/DeviceRPCRequestHandler.java b/acs/requestprocessor/src/main/java/org/commscope/tr069adapter/acs/requestprocessor/handler/DeviceRPCRequestHandler.java
index e42ec6f..0f98e60 100644 (file)
--- a/acs/requestprocessor/src/main/java/org/commscope/tr069adapter/acs/requestprocessor/handler/DeviceRPCRequestHandler.java
+++ b/acs/requestprocessor/src/main/java/org/commscope/tr069adapter/acs/requestprocessor/handler/DeviceRPCRequestHandler.java
@@ -21,7 +21,6 @@ package org.commscope.tr069adapter.acs.requestprocessor.handler;
 \r
 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.TR069_NBI_REQUEST_CF;\r
 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.TR069_NBI_REQUEST_Q;\r
-\r
 import org.commscope.tr069adapter.acs.common.DeviceRPCRequest;\r
 import org.commscope.tr069adapter.acs.common.exception.SessionConcurrentAccessException;\r
 import org.commscope.tr069adapter.acs.common.exception.TR069EventProcessingException;\r
@@ -47,7 +46,7 @@ public class DeviceRPCRequestHandler {
   @JmsListener(destination = TR069_NBI_REQUEST_Q, containerFactory = TR069_NBI_REQUEST_CF)\r
   @Transactional(rollbackFor = Exception.class)\r
   public void onMessage(DeviceRPCRequest mapperDeviceOperationRequest)\r
-      throws SessionConcurrentAccessException {\r
+      throws SessionConcurrentAccessException, TR069EventProcessingException {\r
     logger.debug("Received a JMS message from Mapper for TR069 Device RPC operation");\r
     try {\r
       if (mapperDeviceOperationRequest != null) {\r
@@ -55,12 +54,15 @@ public class DeviceRPCRequestHandler {
         logger.debug("Received a TR069 operation request from Mapper with operation ID: {} ",\r
             mapperDeviceOperationRequest.getOperationId());\r
         tr069RequestProcessEngine.processDeviceRPCRequest(mapperDeviceOperationRequest);\r
+        logger.debug("Processed a TR069 operation request from Mapper with operation ID: {} ",\r
+            mapperDeviceOperationRequest.getOperationId());\r
+\r
       }\r
-    } catch (TR069EventProcessingException ex) {\r
-      logger.error(ex.getMessage());\r
     } finally {\r
       MDC.remove(CLIENT_STR);\r
     }\r
+    logger.debug("Processed JMS message from Mapper for TR069 Device RPC operation");\r
+\r
   }\r
 \r
 }\r