X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=acs%2Fnbi%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Facs%2Fnbi%2Fimpl%2FDeviceInformForwarder.java;fp=acs%2Fnbi%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Facs%2Fnbi%2Fimpl%2FDeviceInformForwarder.java;h=2833f4a4f013c665f1d272132ef1cb41cd6beb09;hb=ce4e2d38e3d42725f61c39dd172325d2def4bc44;hp=6b862970973ba2725795fd9688b5a4a72930b93e;hpb=597b7c7a33b3f636263fd7297e3d257eb6b56175;p=oam%2Ftr069-adapter.git diff --git a/acs/nbi/src/main/java/org/commscope/tr069adapter/acs/nbi/impl/DeviceInformForwarder.java b/acs/nbi/src/main/java/org/commscope/tr069adapter/acs/nbi/impl/DeviceInformForwarder.java index 6b86297..2833f4a 100644 --- a/acs/nbi/src/main/java/org/commscope/tr069adapter/acs/nbi/impl/DeviceInformForwarder.java +++ b/acs/nbi/src/main/java/org/commscope/tr069adapter/acs/nbi/impl/DeviceInformForwarder.java @@ -20,7 +20,6 @@ package org.commscope.tr069adapter.acs.nbi.impl; import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_NOTIFICATION_CF; import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_NOTIFICATION_Q; - import org.commscope.tr069adapter.acs.common.DeviceInform; import org.commscope.tr069adapter.acs.nbi.mapper.service.DeviceEventsMapperNotificationService; import org.slf4j.Logger; @@ -41,19 +40,14 @@ public class DeviceInformForwarder { @JmsListener(destination = NBI_NOTIFICATION_Q, containerFactory = NBI_NOTIFICATION_CF) @Transactional(rollbackFor = Exception.class) public void onMessage(DeviceInform notification) { - try { - if (null != notification) { - logger.debug( - "DeviceNotification message is received for deviceId : {} , Notification Type(s): {}", - notification.getDeviceDetails().getDeviceId(), notification.getInformTypeList()); - deviceEventsMapperNotificationService.processDeviceNotification(notification); - logger.debug("Successfully processed device notification."); - } else { - logger.error("Null device response is received!!!"); - } - } catch (Exception e) { - logger.error("Error while processing the notification, Reason: {}", e.getMessage()); + if (null != notification) { + logger.debug( + "DeviceNotification message is received for deviceId : {} , Notification Type(s): {}", + notification.getDeviceDetails().getDeviceId(), notification.getInformTypeList()); + deviceEventsMapperNotificationService.processDeviceNotification(notification); + logger.debug("Successfully processed device notification."); + } else { + logger.error("Null device response is received!!!"); } } - }