X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=acs%2Fcpe%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Facs%2Fcpe%2Fhandler%2FConnectionReqEventHandler.java;h=afa6a3fdf73ee981bfa90497492bdbf94ddabed3;hb=ce4e2d38e3d42725f61c39dd172325d2def4bc44;hp=c8e76f71bdcd8c6b2ba7cc3b9aa30231a40a43f0;hpb=597b7c7a33b3f636263fd7297e3d257eb6b56175;p=oam%2Ftr069-adapter.git

diff --git a/acs/cpe/src/main/java/org/commscope/tr069adapter/acs/cpe/handler/ConnectionReqEventHandler.java b/acs/cpe/src/main/java/org/commscope/tr069adapter/acs/cpe/handler/ConnectionReqEventHandler.java
index c8e76f7..afa6a3f 100644
--- a/acs/cpe/src/main/java/org/commscope/tr069adapter/acs/cpe/handler/ConnectionReqEventHandler.java
+++ b/acs/cpe/src/main/java/org/commscope/tr069adapter/acs/cpe/handler/ConnectionReqEventHandler.java
@@ -21,9 +21,7 @@ package org.commscope.tr069adapter.acs.cpe.handler;
 
 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.CR_REQ_CF;
 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.CR_REQ_Q;
-
 import java.io.IOException;
-
 import org.commscope.tr069adapter.acs.common.dto.TR069DeviceDetails;
 import org.commscope.tr069adapter.acs.common.exception.SessionManagerException;
 import org.commscope.tr069adapter.acs.cpe.processor.ConnectionReqEventProcessor;
@@ -47,7 +45,8 @@ public class ConnectionReqEventHandler {
 
   @JmsListener(destination = CR_REQ_Q, containerFactory = CR_REQ_CF)
   @Transactional(rollbackFor = Exception.class)
-  public void onMessage(TR069DeviceDetails tr069DeviceDetails) {
+  public void onMessage(TR069DeviceDetails tr069DeviceDetails)
+      throws SessionManagerException, IOException {
     try {
       if (tr069DeviceDetails != null) {
         MDC.put(CLIENT_STR, tr069DeviceDetails.getDeviceId());
@@ -60,8 +59,6 @@ public class ConnectionReqEventHandler {
             "Received a JMS message for initiating connection request with no device details, "
                 + "hence could not initiate connection request");
       }
-    } catch (SessionManagerException | IOException e) {
-      logger.error(e.getMessage());
     } finally {
       MDC.remove(CLIENT_STR);
     }