Commit f4eb5cc6 authored by Christos Tranoris's avatar Christos Tranoris
Browse files

fix resource update

parent 32bf6f4b

src/main/java/org/etsi/osl/metrico/services/MetricoService.java

+15 −1
Original line number Diff line number Diff line
@@ -10,6 +10,7 @@ import org.etsi.osl.metrico.model.Job; 
import org.etsi.osl.metrico.prometheus.PrometheusQueries;

import org.etsi.osl.metrico.repo.JobRepository;

import org.etsi.osl.metrico.reposervices.JobRepoService;

import org.etsi.osl.tmf.common.model.Any;

import org.etsi.osl.tmf.common.model.ELifecycle;

import org.etsi.osl.tmf.common.model.EValueType;

import org.etsi.osl.tmf.common.model.service.ResourceRef;
@@ -195,7 +196,12 @@ public class MetricoService extends RouteBuilder { 
      

      MeasurementCollectionJob givenMCJ = retrieveMeasurementCollectionJob( mcjevent.getEvent().getMeasurementCollectionJob().getId() );



      if ( givenMCJ != null) {

        startPeriodicQueryToPrometheus(givenMCJ);        

      } else {



        logger.error("=======> CANNOT retrieve Measurement Collection Job with mcjId = " + mcjevent.getEvent().getMeasurementCollectionJob().getId()  +" from activeMQ");

      }

  }



    public MeasurementCollectionJob retrieveMeasurementCollectionJob(String mcjId) {
@@ -241,6 +247,14 @@ public class MetricoService extends RouteBuilder { 
        logger.debug("updateRelatedResource resRef = " + resRef.getId() );

        

        ResourceUpdate rup = new ResourceUpdate();

        org.etsi.osl.tmf.ri639.model.Characteristic resCharacteristicItem =  new org.etsi.osl.tmf.ri639.model.Characteristic();

        resCharacteristicItem.setName( "_MT_MCJ_REF" );

        resCharacteristicItem.setValueType( "TEXT" );

        Any val = new Any();

        val.setValue( givenMCJ.getUuid() );

        val.setAlias( "" );

        resCharacteristicItem.setValue( val );

        rup.addResourceCharacteristicItem(  resCharacteristicItem );

        

        if ( givenMCJ.getExecutionState().equals( ExecutionStateType.FAILED  ) ) {

          rup.setResourceStatus( org.etsi.osl.tmf.ri639.model.ResourceStatusType.SUSPENDED );