acs/nbi/src/main/java/org/commscope/tr069adapter/acs/nbi/impl/DeviceRPCResponseForwarder.java

   1 /*
   2  * ============LICENSE_START========================================================================
   3  * ONAP : tr-069-adapter
   4  * =================================================================================================
   5  * Copyright (C) 2020 CommScope Inc Intellectual Property.
   6  * =================================================================================================
   7  * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,
   8  * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You
   9  * may obtain a copy of the License at
  10  *
  11  * http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
  14  * either express or implied. See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  * ===============LICENSE_END=======================================================================
  17  */
  18
  19 package org.commscope.tr069adapter.acs.nbi.impl;
  20
  21 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_OP_RESULT_CF;
  22 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_OP_RESULT_Q;
  23
  24 import org.commscope.tr069adapter.acs.common.DeviceRPCResponse;
  25 import org.commscope.tr069adapter.acs.nbi.mapper.service.DeviceEventsMapperNotificationService;
  26 import org.slf4j.Logger;
  27 import org.slf4j.LoggerFactory;
  28 import org.springframework.beans.factory.annotation.Autowired;
  29 import org.springframework.jms.annotation.JmsListener;
  30 import org.springframework.stereotype.Component;
  31 import org.springframework.transaction.annotation.Transactional;
  32
  33 @Component
  34 public class DeviceRPCResponseForwarder {
  35
  36   private static final Logger logger = LoggerFactory.getLogger(DeviceRPCResponseForwarder.class);
  37
  38   @Autowired
  39   private DeviceEventsMapperNotificationService deviceEventsMapperNotificationService;
  40
  41   @JmsListener(destination = NBI_OP_RESULT_Q, containerFactory = NBI_OP_RESULT_CF)
  42   @Transactional(rollbackFor = Exception.class)
  43   public void onMessage(DeviceRPCResponse opResult) {
  44     if (null != opResult) {
  45       logger.debug("NBIOperationResult message is received for deviceId : {}, , OprationId: {}",
  46           opResult.getDeviceDetails().getDeviceId(), opResult.getOperationId());
  47       deviceEventsMapperNotificationService.processOperationResponse(opResult);
  48       logger.debug("Successfully processed NBI operation result.");
  49     } else {
  50       logger.error("Null device response is received!!!");
  51     }
  52   }
  53 }