FlowDiagram.puml

@startuml FlowDiagram
actor        "ACTOR"              as actor
participant  "OSOM"               as osom
participant  "TMF API"            as tmf_api
queue        amq                  as amq
participant  "METRICO" as metrico
participant  prometheus           as prom


actor   -> tmf_api: CREATE: Service Order Monitoring aaS
osom    -> osom: PROCESS ORDER

osom    -> tmf_api: CREATE: service instance of monitoring aaS (RFS)(Initial Status: Reseved)
osom    -> tmf_api: CREATE: service instance of monitoring aaS (CFS)(Initial Status: Reseved)

osom    -> amq: CREATE: TMF628 Measurement Collection Job \n<color:green>queue:PM_MEASUREMENT_COLLECTION_JOB_ADD \n<color:green>payload: MeasurementCollectionJobFVO
amq     -> tmf_api: CREATE: TMF628 Measurement Collection Job \n<color:green>queue:PM_MEASUREMENT_COLLECTION_JOB_ADD \n<color:green>payload: MeasurementCollectionJobFVO (Here I can find the MCJ ID)
tmf_api     -> amq: CREATE: TMF628 Measurement Collection Job \n<color:green>queue:PM_MEASUREMENT_COLLECTION_JOB_ADD \n<color:green>payload: MeasurementCollectionJob (Here I can find the MCJ ID)
osom -> tmf_api: CREATE: Resource Instance (Initial Status: Reseved)(associate to RFS)(add the MCJ UUID)
amq     -> osom: CREATE: TMF628 Measurement Collection Job \n<color:green>queue:PM_MEASUREMENT_COLLECTION_JOB_ADD \n<color:green>payload: MeasurementCollectionJob (Here I can find the MCJ ID)
tmf_api -> amq: PUBLISH EVENT: Monitoring Job Created\n<color:green>topic: PM_MEASUREMENT_COLLECTION_JOB_CREATED\n<color:green>payload: Measurement Collection Job Ref
amq     -> metrico: RECEIVE EVENT: Monitoring Job Created\n<color:green>topic: PM_MEASUREMENT_COLLECTION_JOB_CREATED\n<color:green>payload: Measurement Collection Job Ref
metrico -> tmf_api: fetch Measurement Collection Job from ref
tmf_api -> metrico: fetch Measurement Collection Job from ref
metrico    -> metrico: create METRICO job
metrico    -> amq: UPDATE Measurement Collection Job Status


group "java job" 
    metrico -> metrico   : set how often job is done
    metrico -> prom   : send prom req
    prom -> metrico   : reply to prom req
    metrico -> metrico   : parse data from reply and cast them to data access endpoint
    
    metrico -> amq    : UPDATE: Related service to the Service Inventory\n<color:green>queue:jms:queue:CATALOG.UPD.SERVICE \n<color:green>payload: ServiceUpdate, serviceId
    amq  -> tmf_api: UPDATE: Related service to the Service Inventory\n<color:green>queue:jms:queue:CATALOG.UPD.SERVICE \n<color:green>payload: ServiceUpdate, serviceId
end

@enduml