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=b62e61a31abf49c3f9e5508e815aea50a69ee049;hb=76744e810f35c84ecbd1d9998e361052466e9483;hp=2833f4a4f013c665f1d272132ef1cb41cd6beb09;hpb=ce4e2d38e3d42725f61c39dd172325d2def4bc44;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 2833f4a..b62e61a 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 @@ -1,53 +1,54 @@ -/* - * ============LICENSE_START======================================================================== - * ONAP : tr-069-adapter - * ================================================================================================= - * Copyright (C) 2020 CommScope Inc Intellectual Property. - * ================================================================================================= - * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License, - * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You - * may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, - * either express or implied. See the License for the specific language governing permissions and - * limitations under the License. - * ===============LICENSE_END======================================================================= - */ - -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; -import org.slf4j.LoggerFactory; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.jms.annotation.JmsListener; -import org.springframework.stereotype.Component; -import org.springframework.transaction.annotation.Transactional; - -@Component -public class DeviceInformForwarder { - - private static final Logger logger = LoggerFactory.getLogger(DeviceInformForwarder.class); - - @Autowired - private DeviceEventsMapperNotificationService deviceEventsMapperNotificationService; - - @JmsListener(destination = NBI_NOTIFICATION_Q, containerFactory = NBI_NOTIFICATION_CF) - @Transactional(rollbackFor = Exception.class) - public void onMessage(DeviceInform notification) { - 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!!!"); - } - } -} +/* + * ============LICENSE_START======================================================================== + * ONAP : tr-069-adapter + * ================================================================================================= + * Copyright (C) 2020 CommScope Inc Intellectual Property. + * ================================================================================================= + * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License, + * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You + * may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, + * either express or implied. See the License for the specific language governing permissions and + * limitations under the License. + * ===============LICENSE_END======================================================================= + */ + +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; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.jms.annotation.JmsListener; +import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Transactional; + +@Component +public class DeviceInformForwarder { + + private static final Logger logger = LoggerFactory.getLogger(DeviceInformForwarder.class); + + @Autowired + private DeviceEventsMapperNotificationService deviceEventsMapperNotificationService; + + @JmsListener(destination = NBI_NOTIFICATION_Q, containerFactory = NBI_NOTIFICATION_CF) + @Transactional(rollbackFor = Exception.class) + public void onMessage(DeviceInform notification) { + 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!!!"); + } + } +}