csit/resources/tests/data/functional-pmsh-usecase.yaml

   1 # ============LICENSE_START=======================================================
   2 # Copyright (C) 2022 Nordix Foundation.
   3 # ================================================================================
   4 # Licensed under the Apache License, Version 2.0 (the "License");
   5 # you may not use this file except in compliance with the License.
   6 # You may obtain a copy of the License at
   7 #
   8 #     http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 # Unless required by applicable law or agreed to in writing, software
  11 # distributed under the License is distributed on an "AS IS" BASIS,
  12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 # See the License for the specific language governing permissions and
  14 # limitations under the License.
  15 #
  16 # SPDX-License-Identifier: Apache-2.0
  17 # ============LICENSE_END=========================================================
  18 tosca_definitions_version: tosca_simple_yaml_1_3
  19 data_types:
  20   onap.datatypes.ToscaConceptIdentifier:
  21     derived_from: tosca.datatypes.Root
  22     properties:
  23       name:
  24         type: string
  25         required: true
  26       version:
  27         type: string
  28         required: true
  29   onap.datatype.controlloop.Target:
  30     derived_from: tosca.datatypes.Root
  31     description: Definition for a entity in A&AI to perform a control loop operation
  32       on
  33     properties:
  34       targetType:
  35         type: string
  36         description: Category for the target type
  37         required: true
  38         constraints:
  39           - valid_values:
  40               - VNF
  41               - VM
  42               - VFMODULE
  43               - PNF
  44       entityIds:
  45         type: map
  46         description: |
  47           Map of values that identify the resource. If none are provided, it is assumed that the
  48           entity that generated the ONSET event will be the target.
  49         required: false
  50         metadata:
  51           clamp_possible_values: ClampExecution:CSAR_RESOURCES
  52         entry_schema:
  53           type: string
  54   onap.datatype.controlloop.Actor:
  55     derived_from: tosca.datatypes.Root
  56     description: An actor/operation/target definition
  57     properties:
  58       actor:
  59         type: string
  60         description: The actor performing the operation.
  61         required: true
  62         metadata:
  63           clamp_possible_values: Dictionary:DefaultActors,ClampExecution:CDS/actor
  64       operation:
  65         type: string
  66         description: The operation the actor is performing.
  67         metadata:
  68           clamp_possible_values: Dictionary:DefaultOperations,ClampExecution:CDS/operation
  69         required: true
  70       target:
  71         type: onap.datatype.controlloop.Target
  72         description: The resource the operation should be performed on.
  73         required: true
  74       payload:
  75         type: map
  76         description: Name/value pairs of payload information passed by Policy to the
  77           actor
  78         required: false
  79         metadata:
  80           clamp_possible_values: ClampExecution:CDS/payload
  81         entry_schema:
  82           type: string
  83   onap.datatype.controlloop.Operation:
  84     derived_from: tosca.datatypes.Root
  85     description: An operation supported by an actor
  86     properties:
  87       id:
  88         type: string
  89         description: Unique identifier for the operation
  90         required: true
  91       description:
  92         type: string
  93         description: A user-friendly description of the intent for the operation
  94         required: false
  95       operation:
  96         type: onap.datatype.controlloop.Actor
  97         description: The definition of the operation to be performed.
  98         required: true
  99       timeout:
 100         type: integer
 101         description: The amount of time for the actor to perform the operation.
 102         required: true
 103       retries:
 104         type: integer
 105         description: The number of retries the actor should attempt to perform the
 106           operation.
 107         required: true
 108         default: 0
 109       success:
 110         type: string
 111         description: Points to the operation to invoke on success. A value of "final_success"
 112           indicates and end to the operation.
 113         required: false
 114         default: final_success
 115       failure:
 116         type: string
 117         description: Points to the operation to invoke on Actor operation failure.
 118         required: false
 119         default: final_failure
 120       failure_timeout:
 121         type: string
 122         description: Points to the operation to invoke when the time out for the operation
 123           occurs.
 124         required: false
 125         default: final_failure_timeout
 126       failure_retries:
 127         type: string
 128         description: Points to the operation to invoke when the current operation
 129           has exceeded its max retries.
 130         required: false
 131         default: final_failure_retries
 132       failure_exception:
 133         type: string
 134         description: Points to the operation to invoke when the current operation
 135           causes an exception.
 136         required: false
 137         default: final_failure_exception
 138       failure_guard:
 139         type: string
 140         description: Points to the operation to invoke when the current operation
 141           is blocked due to guard policy enforcement.
 142         required: false
 143         default: final_failure_guard
 144   org.onap.datatypes.policy.clamp.acm.httpAutomationCompositionElement.RestRequest:
 145     version: 1.0.0
 146     derived_from: tosca.datatypes.Root
 147     properties:
 148       restRequestId:
 149         type: onap.datatypes.ToscaConceptIdentifier
 150         required: true
 151         description: The name and version of a REST request to be sent to a REST endpoint
 152       httpMethod:
 153         type: string
 154         required: true
 155         constraints:
 156           - valid_values:
 157               - POST
 158               - PUT
 159               - GET
 160               - DELETE
 161         description: The REST method to use
 162       path:
 163         type: string
 164         required: true
 165         description: The path of the REST request relative to the base URL
 166       body:
 167         type: string
 168         required: false
 169         description: The body of the REST request for PUT and POST requests
 170       expectedResponse:
 171         type: integer
 172         required: true
 173         constraints: []
 174         description: THe expected HTTP status code for the REST request
 175   org.onap.datatypes.policy.clamp.acm.httpAutomationCompositionElement.ConfigurationEntity:
 176     version: 1.0.0
 177     derived_from: tosca.datatypes.Root
 178     properties:
 179       configurationEntityId:
 180         type: onap.datatypes.ToscaConceptIdentifier
 181         required: true
 182         description: The name and version of a Configuration Entity to be handled
 183           by the HTTP Automation Composition Element
 184       restSequence:
 185         type: list
 186         entry_schema:
 187           type: org.onap.datatypes.policy.clamp.acm.httpAutomationCompositionElement.RestRequest
 188           type_version: 1.0.0
 189         description: A sequence of REST commands to send to the REST endpoint
 190 policy_types:
 191   onap.policies.Monitoring:
 192     derived_from: tosca.policies.Root
 193     description: a base policy type for all policies that govern monitoring provisioning
 194     version: 1.0.0
 195     name: onap.policies.Monitoring
 196   onap.policies.customPolicyType:
 197     derived_from: tosca.policies.Root
 198     description: a base policy type for all policies that govern monitoring provisioning
 199     version: 1.0.0
 200     name: onap.policies.customPolicyType
 201   onap.policies.controlloop.operational.Common:
 202     derived_from: tosca.policies.Root
 203     version: 1.0.0
 204     name: onap.policies.controlloop.operational.Common
 205     description: |
 206       Operational Policy for Control Loop execution. Originated in Frankfurt to support TOSCA Compliant
 207       Policy Types. This does NOT support the legacy Policy YAML policy type.
 208     properties:
 209       id:
 210         type: string
 211         description: The unique control loop id.
 212         required: true
 213       timeout:
 214         type: integer
 215         description: |
 216           Overall timeout for executing all the operations. This timeout should equal or exceed the total
 217           timeout for each operation listed.
 218         required: true
 219       abatement:
 220         type: boolean
 221         description: Whether an abatement event message will be expected for the control
 222           loop from DCAE.
 223         required: true
 224         default: false
 225       trigger:
 226         type: string
 227         description: Initial operation to execute upon receiving an Onset event message
 228           for the Control Loop.
 229         required: true
 230       operations:
 231         type: list
 232         description: List of operations to be performed when Control Loop is triggered.
 233         required: true
 234         entry_schema:
 235           type: onap.datatype.controlloop.Operation
 236   onap.policies.controlloop.operational.common.Apex:
 237     derived_from: onap.policies.controlloop.operational.Common
 238     type_version: 1.0.0
 239     version: 1.0.0
 240     name: onap.policies.controlloop.operational.common.Apex
 241     description: Operational policies for Apex PDP
 242     properties:
 243       engineServiceParameters:
 244         type: string
 245         description: The engine parameters like name, instanceCount, policy implementation,
 246           parameters etc.
 247         required: true
 248       eventInputParameters:
 249         type: string
 250         description: The event input parameters.
 251         required: true
 252       eventOutputParameters:
 253         type: string
 254         description: The event output parameters.
 255         required: true
 256       javaProperties:
 257         type: string
 258         description: Name/value pairs of properties to be set for APEX if needed.
 259         required: false
 260
 261 node_types:
 262   org.onap.policy.clamp.acm.Participant:
 263     version: 1.0.1
 264     derived_from: tosca.nodetypes.Root
 265     properties:
 266       provider:
 267         type: string
 268         required: false
 269   org.onap.policy.clamp.acm.AutomationCompositionElement:
 270     version: 1.0.1
 271     derived_from: tosca.nodetypes.Root
 272     properties:
 273       provider:
 274         type: string
 275         required: false
 276         metadata:
 277           common: true
 278         description: Specifies the organization that provides the automation composition element
 279       participant_id:
 280         type: onap.datatypes.ToscaConceptIdentifier
 281         required: true
 282         metadata:
 283           common: true
 284       participantType:
 285         type: onap.datatypes.ToscaConceptIdentifier
 286         required: true
 287         metadata:
 288           common: true
 289         description: The identity of the participant type that hosts this type of Automation Composition Element
 290       startPhase:
 291         type: integer
 292         required: false
 293         constraints:
 294           - greater_or_equal: 0
 295         metadata:
 296           common: true
 297         description: A value indicating the start phase in which this automation composition element will be started, the
 298           first start phase is zero. Automation Composition Elements are started in their start_phase order and stopped
 299           in reverse start phase order. Automation Composition Elements with the same start phase are started and
 300           stopped simultaneously
 301       uninitializedToPassiveTimeout:
 302         type: integer
 303         required: false
 304         constraints:
 305           - greater_or_equal: 0
 306         default: 60
 307         metadata:
 308           common: true
 309         description: The maximum time in seconds to wait for a state chage from uninitialized to passive
 310       passiveToRunningTimeout:
 311         type: integer
 312         required: false
 313         constraints:
 314           - greater_or_equal: 0
 315         default: 60
 316         metadata:
 317           common: true
 318         description: The maximum time in seconds to wait for a state chage from passive to running
 319       runningToPassiveTimeout:
 320         type: integer
 321         required: false
 322         constraints:
 323           - greater_or_equal: 0
 324         default: 60
 325         metadata:
 326           common: true
 327         description: The maximum time in seconds to wait for a state chage from running to passive
 328       passiveToUninitializedTimeout:
 329         type: integer
 330         required: false
 331         constraints:
 332           - greater_or_equal: 0
 333         default: 60
 334         metadata:
 335           common: true
 336         description: The maximum time in seconds to wait for a state chage from passive to uninitialized
 337   org.onap.policy.clamp.acm.AutomationComposition:
 338     version: 1.0.1
 339     derived_from: tosca.nodetypes.Root
 340     properties:
 341       provider:
 342         type: string
 343         required: false
 344         metadata:
 345           common: true
 346         description: Specifies the organization that provides the automation composition element
 347       elements:
 348         type: list
 349         required: true
 350         metadata:
 351           common: true
 352         entry_schema:
 353           type: onap.datatypes.ToscaConceptIdentifier
 354         description: Specifies a list of automation composition element definitions that make up this automation composition definition
 355   org.onap.policy.clamp.acm.PolicyAutomationCompositionElement:
 356     version: 1.0.1
 357     derived_from: org.onap.policy.clamp.acm.AutomationCompositionElement
 358     properties:
 359       policy_type_id:
 360         type: onap.datatypes.ToscaConceptIdentifier
 361         required: true
 362       policy_id:
 363         type: onap.datatypes.ToscaConceptIdentifier
 364         required: false
 365   org.onap.policy.clamp.acm.CDSAutomationCompositionElement:
 366     version: 1.0.1
 367     derived_from: org.onap.policy.clamp.acm.AutomationCompositionElement
 368     properties:
 369       cds_blueprint_id:
 370         type: onap.datatypes.ToscaConceptIdentifier
 371         required: true
 372   org.onap.policy.clamp.acm.K8SMicroserviceAutomationCompositionElement:
 373     version: 1.0.1
 374     derived_from: org.onap.policy.clamp.acm.AutomationCompositionElement
 375     properties:
 376       chart:
 377         type: string
 378         required: true
 379       configs:
 380         type: list
 381         required: false
 382       requirements:
 383         type: string
 384         required: false
 385       templates:
 386         type: list
 387         required: false
 388         entry_schema:
 389       values:
 390         type: string
 391         required: true
 392   org.onap.policy.clamp.acm.HttpAutomationCompositionElement:
 393     version: 1.0.1
 394     derived_from: org.onap.policy.clamp.acm.AutomationCompositionElement
 395     properties:
 396       baseUrl:
 397         type: string
 398         required: true
 399         description: The base URL to be prepended to each path, identifies the host for the REST endpoints.
 400       httpHeaders:
 401         type: map
 402         required: false
 403         entry_schema:
 404           type: string
 405         description: HTTP headers to send on REST requests
 406       configurationEntities:
 407         type: map
 408         required: true
 409         entry_schema:
 410           type: org.onap.datatypes.policy.clamp.acm.httpAutomationCompositionElement.ConfigurationEntity
 411           type_version: 1.0.0
 412         description: The connfiguration entities the Automation Composition Element is managing and their associated REST requests
 413
 414 topology_template:
 415   inputs:
 416     pmsh_operational_policy:
 417       type: onap.datatypes.ToscaConceptIdentifier
 418       description: The ID of the PMSH operational policy to use
 419       default:
 420         name: operational.apex.pmcontrol
 421         version: 1.0.0
 422   node_templates:
 423     org.onap.policy.clamp.acm.PolicyParticipant:
 424       version: 2.3.1
 425       type: org.onap.policy.clamp.acm.Participant
 426       type_version: 1.0.1
 427       description: Participant for DCAE microservices
 428       properties:
 429         provider: ONAP
 430     org.onap.domain.pmsh.PMSH_OperationalPolicyAutomationCompositionElement:
 431       version: 1.2.3
 432       type: org.onap.policy.clamp.acm.PolicyAutomationCompositionElement
 433       type_version: 1.0.1
 434       description: Automation composition element for the operational policy for Performance Management Subscription Handling
 435       properties:
 436         provider: Ericsson
 437         participant_id:
 438           name: org.onap.PM_Policy
 439           version: 1.0.0
 440         participantType:
 441           name: org.onap.policy.clamp.acm.PolicyParticipant
 442           version: 2.3.1
 443         policy_type_id:
 444           name: onap.policies.operational.pm-subscription-handler
 445           version: 1.0.0
 446         policy_id:
 447           get_input: pmsh_operational_policy
 448
 449
 450     org.onap.policy.clamp.acm.KubernetesParticipant:
 451       version: 2.3.4
 452       type: org.onap.policy.clamp.acm.Participant
 453       type_version: 1.0.1
 454       description: Participant for K8S
 455       properties:
 456         provider: ONAP
 457     org.onap.domain.database.PMSH_K8SMicroserviceAutomationCompositionElement:
 458       # Chart from new repository
 459       version: 1.2.3
 460       type: org.onap.policy.clamp.acm.K8SMicroserviceAutomationCompositionElement
 461       type_version: 1.0.1
 462       description: Automation composition element for the K8S microservice for PMSH
 463       properties:
 464         provider: ONAP
 465         participant_id:
 466           name: K8sParticipant0
 467           version: 1.0.0
 468         participantType:
 469           name: org.onap.policy.clamp.acm.KubernetesParticipant
 470           version: 2.3.4
 471         chart:
 472           chartId:
 473             name: dcae-pmsh
 474             version: 10.0.0
 475           namespace: onap
 476           releaseName: dcae-pmsh
 477           repository:
 478             repoName: chartmuseum
 479             address: http://chart-museum:80
 480             userName: onapinitializer
 481             password: demo123456!
 482           overrideParams:
 483             global.masterPassword: test
 484             global.centralizedLoggingEnabled: false
 485     org.onap.policy.clamp.acm.HttpParticipant:
 486       version: 2.3.4
 487       type: org.onap.policy.clamp.acm.Participant
 488       type_version: 1.0.1
 489       description: Participant for Http requests
 490       properties:
 491         provider: ONAP
 492     org.onap.domain.database.Http_PMSHMicroserviceAutomationCompositionElement:
 493       # Http config for PMSH.
 494       version: 1.2.3
 495       type: org.onap.policy.clamp.acm.HttpAutomationCompositionElement
 496       type_version: 1.0.1
 497       description: Automation composition element for the http requests of PMSH microservice
 498       properties:
 499         provider: ONAP
 500         participant_id:
 501           name: HttpParticipant0
 502           version: 1.0.0
 503         participantType:
 504           name: org.onap.policy.clamp.acm.HttpParticipant
 505           version: 2.3.4
 506         uninitializedToPassiveTimeout: 180
 507         startPhase: 1
 508         baseUrl: https://dcae-pmsh:8443
 509         httpHeaders:
 510           Content-Type: application/json
 511         configurationEntities:
 512           - configurationEntityId:
 513               name: entity1
 514               version: 1.0.1
 515             restSequence:
 516               - restRequestId:
 517                   name: request1
 518                   version: 1.0.1
 519                 httpMethod: POST
 520                 path: subscription
 521                 body: '{
 522                          "subscription":{
 523                          "subscriptionName":"new_sub_01",
 524                          "operationalPolicyName":"pmsh-operational-policy",
 525                          "controlLoopName":"controlLoop-name",
 526                          "nfFilter":{
 527                          "nfNames":[
 528                                 "^pnf*"
 529                          ],
 530                          "modelInvariantIDs":[
 531                             "7129e420-d396-4efb-af02-6b83499b12f5"
 532                          ],
 533                             "modelVersionIDs":[
 534                          "e80a6ae3-cafd-4d24-850d-e14c084a5ca7"
 535                          ],
 536                         "modelNames":[
 537                         "pnf_134"
 538                         ]
 539                         },
 540                         "measurementGroups":[
 541                         {
 542                             "measurementGroup":{
 543                             "measurementGroupName":"msgroup_01",
 544                             "administrativeState":"UNLOCKED",
 545                             "fileBasedGP":15,
 546                             "fileLocation":"/pm/pm.xml",
 547                             "measurementTypes":[
 548                             {
 549                             "measurementType":"EutranCell.*"
 550                             },
 551                             {
 552                             "measurementType":"EutranCellRelation.pmCounter1"
 553                             },
 554                             {
 555                             "measurementType":"EutranCellRelation.pmCounter2"
 556                             }
 557                         ],
 558                         "managedObjectDNsBasic":[
 559                         {
 560                         "DN":"ManagedElement=1,ENodeBFunction=1,EUtranCell=CityCenter1"
 561                         },
 562                         {
 563                         "DN":"ManagedElement=1,ENodeBFunction=1,EUtranCell=CityCenter1, EUtranCellRelation=CityCenter2"
 564                         },
 565                         {
 566                         "DN":"ManagedElement=1,ENodeBFunction=1,EUtranCell=CityCenter1, EUtranCellRelation=CityCenter3"
 567                         }
 568                         ]
 569                         }
 570                             }
 571                         ]
 572                         }
 573                 }'
 574                 expectedResponse: 201
 575
 576
 577     org.onap.domain.pmsh.PMSHAutomationCompositionDefinition:
 578       version: 1.2.3
 579       type: org.onap.policy.clamp.acm.AutomationComposition
 580       type_version: 1.0.1
 581       description: Automation composition for PMSH
 582       properties:
 583         provider: ONAP
 584         elements:
 585           - name: org.onap.domain.database.PMSH_K8SMicroserviceAutomationCompositionElement
 586             version: 1.2.3
 587           - name: org.onap.domain.database.Http_PMSHMicroserviceAutomationCompositionElement
 588             version: 1.2.3
 589           - name: org.onap.domain.pmsh.PMSH_OperationalPolicyAutomationCompositionElement
 590             version: 1.2.3
 591   policies:
 592     - operational.apex.pmcontrol:
 593         type: onap.policies.controlloop.operational.common.Apex
 594         type_version: 1.0.0
 595         version: 1.0.0
 596         properties:
 597           engineServiceParameters:
 598             name: MyApexEngine
 599             version: 0.0.1
 600             id: 45
 601             instanceCount: 2
 602             deploymentPort: 12561
 603             engineParameters:
 604               executorParameters:
 605                 JAVASCRIPT:
 606                   parameterClassName: org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters
 607               contextParameters:
 608                 parameterClassName: org.onap.policy.apex.context.parameters.ContextParameters
 609                 schemaParameters:
 610                   Avro:
 611                     parameterClassName: org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters
 612                   Java:
 613                     parameterClassName: org.onap.policy.apex.context.impl.schema.java.JavaSchemaHelperParameters
 614                     jsonAdapters:
 615                       Instant:
 616                         adaptedClass: java.time.Instant
 617                         adaptorClass: org.onap.policy.common.gson.InstantAsMillisTypeAdapter
 618             policy_type_impl:
 619               apexPolicyModel:
 620                 key:
 621                   name: PMControlPolicy
 622                   version: 0.0.1
 623                 keyInformation:
 624                   key:
 625                     name: PMControlPolicy_KeyInfo
 626                     version: 0.0.1
 627                   keyInfoMap:
 628                     entry:
 629                       - key:
 630                           name: CDSActionIdentifiersType
 631                           version: 0.0.1
 632                         value:
 633                           key:
 634                             name: CDSActionIdentifiersType
 635                             version: 0.0.1
 636                           UUID: 6e5fa19b-14df-37e3-a4ae-8c537e861a82
 637                           description: Generated description for concept referred to by
 638                             key "CDSActionIdentifiersType:0.0.1"
 639                       - key:
 640                           name: CDSCreateResponseEvent
 641                           version: 0.0.1
 642                         value:
 643                           key:
 644                             name: CDSCreateResponseEvent
 645                             version: 0.0.1
 646                           UUID: 14b29e38-ac75-3273-aa4e-8583c0aa7dad
 647                           description: Generated description for concept referred to by
 648                             key "CDSCreateResponseEvent:0.0.1"
 649                       - key:
 650                           name: CDSCreateResponsePayloadType
 651                           version: 0.0.1
 652                         value:
 653                           key:
 654                             name: CDSCreateResponsePayloadType
 655                             version: 0.0.1
 656                           UUID: 04573f8f-e772-30a5-b1d9-d7318d4a1e13
 657                           description: Generated description for concept referred to by
 658                             key "CDSCreateResponsePayloadType:0.0.1"
 659                       - key:
 660                           name: CDSCreateResponsePolicy
 661                           version: 0.0.1
 662                         value:
 663                           key:
 664                             name: CDSCreateResponsePolicy
 665                             version: 0.0.1
 666                           UUID: e126c965-fc09-3bfe-8f55-70f380a4a49c
 667                           description: Generated description for concept referred to by
 668                             key "CDSCreateResponsePolicy:0.0.1"
 669                       - key:
 670                           name: CDSCreateResponseTask
 671                           version: 0.0.1
 672                         value:
 673                           key:
 674                             name: CDSCreateResponseTask
 675                             version: 0.0.1
 676                           UUID: 6165ee82-afd2-3aab-a517-f00b3f2461d2
 677                           description: Generated description for concept referred to by
 678                             key "CDSCreateResponseTask:0.0.1"
 679                       - key:
 680                           name: CDSCreateSubscriptionPayloadType
 681                           version: 0.0.1
 682                         value:
 683                           key:
 684                             name: CDSCreateSubscriptionPayloadType
 685                             version: 0.0.1
 686                           UUID: 8350ac5e-c157-38b9-9614-a0f93a830e60
 687                           description: Generated description for concept referred to by
 688                             key "CDSCreateSubscriptionPayloadType:0.0.1"
 689                       - key:
 690                           name: CDSCreateSubscriptionRequestEvent
 691                           version: 0.0.1
 692                         value:
 693                           key:
 694                             name: CDSCreateSubscriptionRequestEvent
 695                             version: 0.0.1
 696                           UUID: cfa325ba-226b-3a31-9183-ec43e2b6e9a2
 697                           description: Generated description for concept referred to by
 698                             key "CDSCreateSubscriptionRequestEvent:0.0.1"
 699                       - key:
 700                           name: CDSDeleteResponseEvent
 701                           version: 0.0.1
 702                         value:
 703                           key:
 704                             name: CDSDeleteResponseEvent
 705                             version: 0.0.1
 706                           UUID: 8be9c0fa-7437-3841-aff2-b3cec6ae3bd8
 707                           description: Generated description for concept referred to by
 708                             key "CDSDeleteResponseEvent:0.0.1"
 709                       - key:
 710                           name: CDSDeleteResponsePayloadType
 711                           version: 0.0.1
 712                         value:
 713                           key:
 714                             name: CDSDeleteResponsePayloadType
 715                             version: 0.0.1
 716                           UUID: 3fbfe0c9-152e-34d3-a504-09cd13c058d0
 717                           description: Generated description for concept referred to by
 718                             key "CDSDeleteResponsePayloadType:0.0.1"
 719                       - key:
 720                           name: CDSDeleteResponsePolicy
 721                           version: 0.0.1
 722                         value:
 723                           key:
 724                             name: CDSDeleteResponsePolicy
 725                             version: 0.0.1
 726                           UUID: a780251c-edd5-3132-b865-04313246b43c
 727                           description: Generated description for concept referred to by
 728                             key "CDSDeleteResponsePolicy:0.0.1"
 729                       - key:
 730                           name: CDSDeleteResponseTask
 731                           version: 0.0.1
 732                         value:
 733                           key:
 734                             name: CDSDeleteResponseTask
 735                             version: 0.0.1
 736                           UUID: afce4555-3aa3-3521-a7d8-ee8cdf0d3efc
 737                           description: Generated description for concept referred to by
 738                             key "CDSDeleteResponseTask:0.0.1"
 739                       - key:
 740                           name: CDSDeleteSubscriptionPayloadType
 741                           version: 0.0.1
 742                         value:
 743                           key:
 744                             name: CDSDeleteSubscriptionPayloadType
 745                             version: 0.0.1
 746                           UUID: 12658406-9147-3c9d-a38c-5ad5e30b092b
 747                           description: Generated description for concept referred to by
 748                             key "CDSDeleteSubscriptionPayloadType:0.0.1"
 749                       - key:
 750                           name: CDSDeleteSubscriptionRequestEvent
 751                           version: 0.0.1
 752                         value:
 753                           key:
 754                             name: CDSDeleteSubscriptionRequestEvent
 755                             version: 0.0.1
 756                           UUID: 24380c95-9289-36e6-8cbf-0edefa15ccd9
 757                           description: Generated description for concept referred to by
 758                             key "CDSDeleteSubscriptionRequestEvent:0.0.1"
 759                       - key:
 760                           name: CDSRequestCommonHeaderType
 761                           version: 0.0.1
 762                         value:
 763                           key:
 764                             name: CDSRequestCommonHeaderType
 765                             version: 0.0.1
 766                           UUID: 35590ac0-062c-39f1-8786-b4ff716e30b1
 767                           description: Generated description for concept referred to by
 768                             key "CDSRequestCommonHeaderType:0.0.1"
 769                       - key:
 770                           name: CDSResponseCommonHeaderType
 771                           version: 0.0.1
 772                         value:
 773                           key:
 774                             name: CDSResponseCommonHeaderType
 775                             version: 0.0.1
 776                           UUID: dd7e1805-885a-350b-aaf9-ed541321ae3c
 777                           description: Generated description for concept referred to by
 778                             key "CDSResponseCommonHeaderType:0.0.1"
 779                       - key:
 780                           name: CDSResponseStatusEvent
 781                           version: 0.0.1
 782                         value:
 783                           key:
 784                             name: CDSResponseStatusEvent
 785                             version: 0.0.1
 786                           UUID: 7986e21b-32f7-302e-9554-31f21b673493
 787                           description: Generated description for concept referred to by
 788                             key "CDSResponseStatusEvent:0.0.1"
 789                       - key:
 790                           name: CDSResponseStatusType
 791                           version: 0.0.1
 792                         value:
 793                           key:
 794                             name: CDSResponseStatusType
 795                             version: 0.0.1
 796                           UUID: 92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa
 797                           description: Generated description for concept referred to by
 798                             key "CDSResponseStatusType:0.0.1"
 799                       - key:
 800                           name: CreateSubscriptionPayloadEvent
 801                           version: 0.0.1
 802                         value:
 803                           key:
 804                             name: CreateSubscriptionPayloadEvent
 805                             version: 0.0.1
 806                           UUID: 92162397-1a8e-3a3f-a469-d2af7700af4a
 807                           description: Generated description for concept referred to by
 808                             key "CreateSubscriptionPayloadEvent:0.0.1"
 809                       - key:
 810                           name: CreateSubscriptionPayloadTask
 811                           version: 0.0.1
 812                         value:
 813                           key:
 814                             name: CreateSubscriptionPayloadTask
 815                             version: 0.0.1
 816                           UUID: bc0c69f0-52ed-38ea-b468-ae4a6fd1730d
 817                           description: Generated description for concept referred to by
 818                             key "CreateSubscriptionPayloadTask:0.0.1"
 819                       - key:
 820                           name: CreateSubscriptionRequestTask
 821                           version: 0.0.1
 822                         value:
 823                           key:
 824                             name: CreateSubscriptionRequestTask
 825                             version: 0.0.1
 826                           UUID: 89cb75e9-f06c-30d3-b4ff-698d45f63869
 827                           description: Generated description for concept referred to by
 828                             key "CreateSubscriptionRequestTask:0.0.1"
 829                       - key:
 830                           name: DeleteSubscriptionPayloadEvent
 831                           version: 0.0.1
 832                         value:
 833                           key:
 834                             name: DeleteSubscriptionPayloadEvent
 835                             version: 0.0.1
 836                           UUID: 994fa441-04ab-33bb-832d-1cd12ab5d074
 837                           description: Generated description for concept referred to by
 838                             key "DeleteSubscriptionPayloadEvent:0.0.1"
 839                       - key:
 840                           name: DeleteSubscriptionPayloadTask
 841                           version: 0.0.1
 842                         value:
 843                           key:
 844                             name: DeleteSubscriptionPayloadTask
 845                             version: 0.0.1
 846                           UUID: 0f519117-5fea-3e4b-941f-8f778100465f
 847                           description: Generated description for concept referred to by
 848                             key "DeleteSubscriptionPayloadTask:0.0.1"
 849                       - key:
 850                           name: DeleteSubscriptionRequestTask
 851                           version: 0.0.1
 852                         value:
 853                           key:
 854                             name: DeleteSubscriptionRequestTask
 855                             version: 0.0.1
 856                           UUID: acb772fe-d442-39e3-98f9-b1080caf4150
 857                           description: Generated description for concept referred to by
 858                             key "DeleteSubscriptionRequestTask:0.0.1"
 859                       - key:
 860                           name: MRResponseEvent
 861                           version: 0.0.1
 862                         value:
 863                           key:
 864                             name: MRResponseEvent
 865                             version: 0.0.1
 866                           UUID: 13c747a3-6bae-3bcf-9c80-b152e01dc194
 867                           description: Generated description for concept referred to by
 868                             key "MRResponseEvent:0.0.1"
 869                       - key:
 870                           name: PMControlPolicy
 871                           version: 0.0.1
 872                         value:
 873                           key:
 874                             name: PMControlPolicy
 875                             version: 0.0.1
 876                           UUID: acf1e55c-7bc5-3bd5-975a-0ca54afcd8a4
 877                           description: Generated description for concept referred to by
 878                             key "PMControlPolicy:0.0.1"
 879                       - key:
 880                           name: PMControlPolicy_Albums
 881                           version: 0.0.1
 882                         value:
 883                           key:
 884                             name: PMControlPolicy_Albums
 885                             version: 0.0.1
 886                           UUID: b38ad204-c2c8-32f4-9b5a-dda0aeb0145b
 887                           description: Generated description for concept referred to by
 888                             key "PMControlPolicy_Albums:0.0.1"
 889                       - key:
 890                           name: PMControlPolicy_Events
 891                           version: 0.0.1
 892                         value:
 893                           key:
 894                             name: PMControlPolicy_Events
 895                             version: 0.0.1
 896                           UUID: be3871a0-c42a-3113-a066-82d192840eca
 897                           description: Generated description for concept referred to by
 898                             key "PMControlPolicy_Events:0.0.1"
 899                       - key:
 900                           name: PMControlPolicy_KeyInfo
 901                           version: 0.0.1
 902                         value:
 903                           key:
 904                             name: PMControlPolicy_KeyInfo
 905                             version: 0.0.1
 906                           UUID: ced37634-28a4-3178-b7f6-2980794927b0
 907                           description: Generated description for concept referred to by
 908                             key "PMControlPolicy_KeyInfo:0.0.1"
 909                       - key:
 910                           name: PMControlPolicy_Policies
 911                           version: 0.0.1
 912                         value:
 913                           key:
 914                             name: PMControlPolicy_Policies
 915                             version: 0.0.1
 916                           UUID: be3d180d-ef9c-3a75-8e9c-84271a038bed
 917                           description: Generated description for concept referred to by
 918                             key "PMControlPolicy_Policies:0.0.1"
 919                       - key:
 920                           name: PMControlPolicy_Schemas
 921                           version: 0.0.1
 922                         value:
 923                           key:
 924                             name: PMControlPolicy_Schemas
 925                             version: 0.0.1
 926                           UUID: e61973f1-189c-39e5-82f6-0d3afe298a20
 927                           description: Generated description for concept referred to by
 928                             key "PMControlPolicy_Schemas:0.0.1"
 929                       - key:
 930                           name: PMControlPolicy_Tasks
 931                           version: 0.0.1
 932                         value:
 933                           key:
 934                             name: PMControlPolicy_Tasks
 935                             version: 0.0.1
 936                           UUID: 5658adb3-2962-30a3-a241-fae75bb8eb4a
 937                           description: Generated description for concept referred to by
 938                             key "PMControlPolicy_Tasks:0.0.1"
 939                       - key:
 940                           name: PMSubscriptionAlbum
 941                           version: 0.0.1
 942                         value:
 943                           key:
 944                             name: PMSubscriptionAlbum
 945                             version: 0.0.1
 946                           UUID: c2bd6f0d-6854-317a-9be2-97c08338428c
 947                           description: Generated description for concept referred to by
 948                             key "PMSubscriptionAlbum:0.0.1"
 949                       - key:
 950                           name: PMSubscriptionOutputEvent
 951                           version: 0.0.1
 952                         value:
 953                           key:
 954                             name: PMSubscriptionOutputEvent
 955                             version: 0.0.1
 956                           UUID: 992b7819-9f69-3aa0-bb0f-6e45ea15ce05
 957                           description: Generated description for concept referred to by
 958                             key "PMSubscriptionOutputEvent:0.0.1"
 959                       - key:
 960                           name: PMSubscriptionType
 961                           version: 0.0.1
 962                         value:
 963                           key:
 964                             name: PMSubscriptionType
 965                             version: 0.0.1
 966                           UUID: 73c1c397-4fc3-357f-93b6-a8ad707fbaae
 967                           description: Generated description for concept referred to by
 968                             key "PMSubscriptionType:0.0.1"
 969                       - key:
 970                           name: ReceiveEventPolicy
 971                           version: 0.0.1
 972                         value:
 973                           key:
 974                             name: ReceiveEventPolicy
 975                             version: 0.0.1
 976                           UUID: 568b7345-9de1-36d3-b6a3-9b857e6809a1
 977                           description: Generated description for concept referred to by
 978                             key "ReceiveEventPolicy:0.0.1"
 979                       - key:
 980                           name: ReceiveSubscriptionTask
 981                           version: 0.0.1
 982                         value:
 983                           key:
 984                             name: ReceiveSubscriptionTask
 985                             version: 0.0.1
 986                           UUID: f596afc8-100c-35eb-92c8-352355ea457d
 987                           description: Generated description for concept referred to by
 988                             key "ReceiveSubscriptionTask:0.0.1"
 989                       - key:
 990                           name: SimpleIntType
 991                           version: 0.0.1
 992                         value:
 993                           key:
 994                             name: SimpleIntType
 995                             version: 0.0.1
 996                           UUID: 153791fd-ae0a-36a7-88a5-309a7936415d
 997                           description: Generated description for concept referred to by
 998                             key "SimpleIntType:0.0.1"
 999                       - key:
1000                           name: SimpleStringType
1001                           version: 0.0.1
1002                         value:
1003                           key:
1004                             name: SimpleStringType
1005                             version: 0.0.1
1006                           UUID: 8a4957cf-9493-3a76-8c22-a208e23259af
1007                           description: Generated description for concept referred to by
1008                             key "SimpleStringType:0.0.1"
1009                       - key:
1010                           name: SubscriptionStatusType
1011                           version: 0.0.1
1012                         value:
1013                           key:
1014                             name: SubscriptionStatusType
1015                             version: 0.0.1
1016                           UUID: 597643b1-9db1-31ce-85d0-e1c63c43b30b
1017                           description: Generated description for concept referred to by
1018                             key "SubscriptionStatusType:0.0.1"
1019                       - key:
1020                           name: SubscriptionType
1021                           version: 0.0.1
1022                         value:
1023                           key:
1024                             name: SubscriptionType
1025                             version: 0.0.1
1026                           UUID: 184547bb-7d64-3cb2-a273-d7185102c5ce
1027                           description: Generated description for concept referred to by
1028                             key "SubscriptionType:0.0.1"
1029                       - key:
1030                           name: UUIDType
1031                           version: 0.0.1
1032                         value:
1033                           key:
1034                             name: UUIDType
1035                             version: 0.0.1
1036                           UUID: 6a8cc68e-dfc8-3403-9c6d-071c886b319c
1037                           description: Generated description for concept referred to by
1038                             key "UUIDType:0.0.1"
1039                       - key:
1040                           name: pmsh-operational-policy
1041                           version: 0.0.1
1042                         value:
1043                           key:
1044                             name: pmsh-operational-policy
1045                             version: 0.0.1
1046                           UUID: fdf2c9ff-6422-3ea6-b6b6-49b12116265d
1047                           description: Generated description for concept referred to by
1048                             key "pmsh-operational-policy:0.0.1"
1049                 policies:
1050                   key:
1051                     name: PMControlPolicy_Policies
1052                     version: 0.0.1
1053                   policyMap:
1054                     entry:
1055                       - key:
1056                           name: CDSCreateResponsePolicy
1057                           version: 0.0.1
1058                         value:
1059                           policyKey:
1060                             name: CDSCreateResponsePolicy
1061                             version: 0.0.1
1062                           template: Freestyle
1063                           state:
1064                             entry:
1065                               - key: CDSCreateResponseState
1066                                 value:
1067                                   stateKey:
1068                                     parentKeyName: CDSCreateResponsePolicy
1069                                     parentKeyVersion: 0.0.1
1070                                     parentLocalName: 'NULL'
1071                                     localName: CDSCreateResponseState
1072                                   trigger:
1073                                     name: CDSCreateResponseEvent
1074                                     version: 0.0.1
1075                                   stateOutputs:
1076                                     entry:
1077                                       - key: ResponseOutput
1078                                         value:
1079                                           key:
1080                                             parentKeyName: CDSCreateResponsePolicy
1081                                             parentKeyVersion: 0.0.1
1082                                             parentLocalName: CDSCreateResponseState
1083                                             localName: ResponseOutput
1084                                           outgoingEvent:
1085                                             name: CDSResponseStatusEvent
1086                                             version: 0.0.1
1087                                           outgoingEventReference:
1088                                             - name: CDSResponseStatusEvent
1089                                               version: 0.0.1
1090                                           nextState:
1091                                             parentKeyName: 'NULL'
1092                                             parentKeyVersion: 0.0.0
1093                                             parentLocalName: 'NULL'
1094                                             localName: 'NULL'
1095                                   contextAlbumReference: [ ]
1096                                   taskSelectionLogic:
1097                                     key: 'NULL'
1098                                     logicFlavour: UNDEFINED
1099                                     logic: ''
1100                                   stateFinalizerLogicMap:
1101                                     entry: [ ]
1102                                   defaultTask:
1103                                     name: CDSCreateResponseTask
1104                                     version: 0.0.1
1105                                   taskReferences:
1106                                     entry:
1107                                       - key:
1108                                           name: CDSCreateResponseTask
1109                                           version: 0.0.1
1110                                         value:
1111                                           key:
1112                                             parentKeyName: CDSCreateResponsePolicy
1113                                             parentKeyVersion: 0.0.1
1114                                             parentLocalName: CDSCreateResponseState
1115                                             localName: CDSCreateResponsePolicy
1116                                           outputType: DIRECT
1117                                           output:
1118                                             parentKeyName: CDSCreateResponsePolicy
1119                                             parentKeyVersion: 0.0.1
1120                                             parentLocalName: CDSCreateResponseState
1121                                             localName: ResponseOutput
1122                           firstState: CDSCreateResponseState
1123                       - key:
1124                           name: CDSDeleteResponsePolicy
1125                           version: 0.0.1
1126                         value:
1127                           policyKey:
1128                             name: CDSDeleteResponsePolicy
1129                             version: 0.0.1
1130                           template: Freestyle
1131                           state:
1132                             entry:
1133                               - key: CDSDeleteResponseState
1134                                 value:
1135                                   stateKey:
1136                                     parentKeyName: CDSDeleteResponsePolicy
1137                                     parentKeyVersion: 0.0.1
1138                                     parentLocalName: 'NULL'
1139                                     localName: CDSDeleteResponseState
1140                                   trigger:
1141                                     name: CDSDeleteResponseEvent
1142                                     version: 0.0.1
1143                                   stateOutputs:
1144                                     entry:
1145                                       - key: ResponseOutput
1146                                         value:
1147                                           key:
1148                                             parentKeyName: CDSDeleteResponsePolicy
1149                                             parentKeyVersion: 0.0.1
1150                                             parentLocalName: CDSDeleteResponseState
1151                                             localName: ResponseOutput
1152                                           outgoingEvent:
1153                                             name: CDSResponseStatusEvent
1154                                             version: 0.0.1
1155                                           outgoingEventReference:
1156                                             - name: CDSResponseStatusEvent
1157                                               version: 0.0.1
1158                                           nextState:
1159                                             parentKeyName: 'NULL'
1160                                             parentKeyVersion: 0.0.0
1161                                             parentLocalName: 'NULL'
1162                                             localName: 'NULL'
1163                                   contextAlbumReference: [ ]
1164                                   taskSelectionLogic:
1165                                     key: 'NULL'
1166                                     logicFlavour: UNDEFINED
1167                                     logic: ''
1168                                   stateFinalizerLogicMap:
1169                                     entry: [ ]
1170                                   defaultTask:
1171                                     name: CDSDeleteResponseTask
1172                                     version: 0.0.1
1173                                   taskReferences:
1174                                     entry:
1175                                       - key:
1176                                           name: CDSDeleteResponseTask
1177                                           version: 0.0.1
1178                                         value:
1179                                           key:
1180                                             parentKeyName: CDSDeleteResponsePolicy
1181                                             parentKeyVersion: 0.0.1
1182                                             parentLocalName: CDSDeleteResponseState
1183                                             localName: CDSDeleteResponsePolicy
1184                                           outputType: DIRECT
1185                                           output:
1186                                             parentKeyName: CDSDeleteResponsePolicy
1187                                             parentKeyVersion: 0.0.1
1188                                             parentLocalName: CDSDeleteResponseState
1189                                             localName: ResponseOutput
1190                           firstState: CDSDeleteResponseState
1191                       - key:
1192                           name: ReceiveEventPolicy
1193                           version: 0.0.1
1194                         value:
1195                           policyKey:
1196                             name: ReceiveEventPolicy
1197                             version: 0.0.1
1198                           template: Freestyle
1199                           state:
1200                             entry:
1201                               - key: CreateOrDeleteState
1202                                 value:
1203                                   stateKey:
1204                                     parentKeyName: ReceiveEventPolicy
1205                                     parentKeyVersion: 0.0.1
1206                                     parentLocalName: 'NULL'
1207                                     localName: CreateOrDeleteState
1208                                   trigger:
1209                                     name: PMSubscriptionOutputEvent
1210                                     version: 0.0.1
1211                                   stateOutputs:
1212                                     entry:
1213                                       - key: CreateSubscriptionPayload
1214                                         value:
1215                                           key:
1216                                             parentKeyName: ReceiveEventPolicy
1217                                             parentKeyVersion: 0.0.1
1218                                             parentLocalName: CreateOrDeleteState
1219                                             localName: CreateSubscriptionPayload
1220                                           outgoingEvent:
1221                                             name: CreateSubscriptionPayloadEvent
1222                                             version: 0.0.1
1223                                           outgoingEventReference:
1224                                             - name: CreateSubscriptionPayloadEvent
1225                                               version: 0.0.1
1226                                           nextState:
1227                                             parentKeyName: ReceiveEventPolicy
1228                                             parentKeyVersion: 0.0.1
1229                                             parentLocalName: 'NULL'
1230                                             localName: CreateSubscription
1231                                       - key: DeleteSubscriptionPayload
1232                                         value:
1233                                           key:
1234                                             parentKeyName: ReceiveEventPolicy
1235                                             parentKeyVersion: 0.0.1
1236                                             parentLocalName: CreateOrDeleteState
1237                                             localName: DeleteSubscriptionPayload
1238                                           outgoingEvent:
1239                                             name: DeleteSubscriptionPayloadEvent
1240                                             version: 0.0.1
1241                                           outgoingEventReference:
1242                                             - name: DeleteSubscriptionPayloadEvent
1243                                               version: 0.0.1
1244                                           nextState:
1245                                             parentKeyName: ReceiveEventPolicy
1246                                             parentKeyVersion: 0.0.1
1247                                             parentLocalName: 'NULL'
1248                                             localName: DeleteSubscription
1249                                   contextAlbumReference:
1250                                     - name: PMSubscriptionAlbum
1251                                       version: 0.0.1
1252                                   taskSelectionLogic:
1253                                     key: TaskSelectionLogic
1254                                     logicFlavour: JAVASCRIPT
1255                                     logic: |-
1256                                       /*
1257                                        * ============LICENSE_START=======================================================
1258                                        *  Copyright (C) 2020 Nordix. All rights reserved.
1259                                        * ================================================================================
1260                                        * Licensed under the Apache License, Version 2.0 (the "License");
1261                                        * you may not use this file except in compliance with the License.
1262                                        * You may obtain a copy of the License at
1263                                        *
1264                                        *      http://www.apache.org/licenses/LICENSE-2.0
1265                                        *
1266                                        * Unless required by applicable law or agreed to in writing, software
1267                                        * distributed under the License is distributed on an "AS IS" BASIS,
1268                                        * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1269                                        * See the License for the specific language governing permissions and
1270                                        * limitations under the License.
1271                                        *
1272                                        * SPDX-License-Identifier: Apache-2.0
1273                                        * ============LICENSE_END=========================================================
1274                                        */
1275                                       executor.logger.info(executor.subject.id);
1276                                       var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(executor.inFields.get("albumID").toString())
1277                                       var changeType = pmSubscriptionInfo.get("changeType").toString()
1278                                       executor.logger.info("Change Type is " + changeType)
1279                                       if ("CREATE".equals(changeType)) {
1280                                           executor.logger.info("Choosing to create a subscription")
1281                                           executor.subject.getTaskKey("CreateSubscriptionPayloadTask").copyTo(executor.selectedTask);
1282                                       }
1283                                       else if ("DELETE".equals(changeType)) {
1284                                           executor.logger.info("Choosing to delete a subscription")
1285                                           executor.subject.getTaskKey("DeleteSubscriptionPayloadTask").copyTo(executor.selectedTask);
1286                                       }
1287                                       returnValue = executor.isTrue;
1288                                       true;
1289                                   stateFinalizerLogicMap:
1290                                     entry: [ ]
1291                                   defaultTask:
1292                                     name: CreateSubscriptionPayloadTask
1293                                     version: 0.0.1
1294                                   taskReferences:
1295                                     entry:
1296                                       - key:
1297                                           name: CreateSubscriptionPayloadTask
1298                                           version: 0.0.1
1299                                         value:
1300                                           key:
1301                                             parentKeyName: ReceiveEventPolicy
1302                                             parentKeyVersion: 0.0.1
1303                                             parentLocalName: CreateOrDeleteState
1304                                             localName: ReceiveEventPolicy
1305                                           outputType: DIRECT
1306                                           output:
1307                                             parentKeyName: ReceiveEventPolicy
1308                                             parentKeyVersion: 0.0.1
1309                                             parentLocalName: CreateOrDeleteState
1310                                             localName: CreateSubscriptionPayload
1311                                       - key:
1312                                           name: DeleteSubscriptionPayloadTask
1313                                           version: 0.0.1
1314                                         value:
1315                                           key:
1316                                             parentKeyName: ReceiveEventPolicy
1317                                             parentKeyVersion: 0.0.1
1318                                             parentLocalName: CreateOrDeleteState
1319                                             localName: ReceiveEventPolicy
1320                                           outputType: DIRECT
1321                                           output:
1322                                             parentKeyName: ReceiveEventPolicy
1323                                             parentKeyVersion: 0.0.1
1324                                             parentLocalName: CreateOrDeleteState
1325                                             localName: DeleteSubscriptionPayload
1326                               - key: CreateSubscription
1327                                 value:
1328                                   stateKey:
1329                                     parentKeyName: ReceiveEventPolicy
1330                                     parentKeyVersion: 0.0.1
1331                                     parentLocalName: 'NULL'
1332                                     localName: CreateSubscription
1333                                   trigger:
1334                                     name: CreateSubscriptionPayloadEvent
1335                                     version: 0.0.1
1336                                   stateOutputs:
1337                                     entry:
1338                                       - key: IssueCreateSubscriptionRequestOutput
1339                                         value:
1340                                           key:
1341                                             parentKeyName: ReceiveEventPolicy
1342                                             parentKeyVersion: 0.0.1
1343                                             parentLocalName: CreateSubscription
1344                                             localName: IssueCreateSubscriptionRequestOutput
1345                                           outgoingEvent:
1346                                             name: CDSCreateSubscriptionRequestEvent
1347                                             version: 0.0.1
1348                                           outgoingEventReference:
1349                                             - name: CDSCreateSubscriptionRequestEvent
1350                                               version: 0.0.1
1351                                           nextState:
1352                                             parentKeyName: 'NULL'
1353                                             parentKeyVersion: 0.0.0
1354                                             parentLocalName: 'NULL'
1355                                             localName: 'NULL'
1356                                   contextAlbumReference:
1357                                     - name: PMSubscriptionAlbum
1358                                       version: 0.0.1
1359                                   taskSelectionLogic:
1360                                     key: 'NULL'
1361                                     logicFlavour: UNDEFINED
1362                                     logic: ''
1363                                   stateFinalizerLogicMap:
1364                                     entry: [ ]
1365                                   defaultTask:
1366                                     name: CreateSubscriptionRequestTask
1367                                     version: 0.0.1
1368                                   taskReferences:
1369                                     entry:
1370                                       - key:
1371                                           name: CreateSubscriptionRequestTask
1372                                           version: 0.0.1
1373                                         value:
1374                                           key:
1375                                             parentKeyName: ReceiveEventPolicy
1376                                             parentKeyVersion: 0.0.1
1377                                             parentLocalName: CreateSubscription
1378                                             localName: ReceiveEventPolicy
1379                                           outputType: DIRECT
1380                                           output:
1381                                             parentKeyName: ReceiveEventPolicy
1382                                             parentKeyVersion: 0.0.1
1383                                             parentLocalName: CreateSubscription
1384                                             localName: IssueCreateSubscriptionRequestOutput
1385                               - key: DeleteSubscription
1386                                 value:
1387                                   stateKey:
1388                                     parentKeyName: ReceiveEventPolicy
1389                                     parentKeyVersion: 0.0.1
1390                                     parentLocalName: 'NULL'
1391                                     localName: DeleteSubscription
1392                                   trigger:
1393                                     name: DeleteSubscriptionPayloadEvent
1394                                     version: 0.0.1
1395                                   stateOutputs:
1396                                     entry:
1397                                       - key: IssueDeleteSubscriptionRequestOutput
1398                                         value:
1399                                           key:
1400                                             parentKeyName: ReceiveEventPolicy
1401                                             parentKeyVersion: 0.0.1
1402                                             parentLocalName: DeleteSubscription
1403                                             localName: IssueDeleteSubscriptionRequestOutput
1404                                           outgoingEvent:
1405                                             name: CDSDeleteSubscriptionRequestEvent
1406                                             version: 0.0.1
1407                                           outgoingEventReference:
1408                                             - name: CDSDeleteSubscriptionRequestEvent
1409                                               version: 0.0.1
1410                                           nextState:
1411                                             parentKeyName: 'NULL'
1412                                             parentKeyVersion: 0.0.0
1413                                             parentLocalName: 'NULL'
1414                                             localName: 'NULL'
1415                                   contextAlbumReference:
1416                                     - name: PMSubscriptionAlbum
1417                                       version: 0.0.1
1418                                   taskSelectionLogic:
1419                                     key: 'NULL'
1420                                     logicFlavour: UNDEFINED
1421                                     logic: ''
1422                                   stateFinalizerLogicMap:
1423                                     entry: [ ]
1424                                   defaultTask:
1425                                     name: DeleteSubscriptionRequestTask
1426                                     version: 0.0.1
1427                                   taskReferences:
1428                                     entry:
1429                                       - key:
1430                                           name: DeleteSubscriptionRequestTask
1431                                           version: 0.0.1
1432                                         value:
1433                                           key:
1434                                             parentKeyName: ReceiveEventPolicy
1435                                             parentKeyVersion: 0.0.1
1436                                             parentLocalName: DeleteSubscription
1437                                             localName: ReceiveEventPolicy
1438                                           outputType: DIRECT
1439                                           output:
1440                                             parentKeyName: ReceiveEventPolicy
1441                                             parentKeyVersion: 0.0.1
1442                                             parentLocalName: DeleteSubscription
1443                                             localName: IssueDeleteSubscriptionRequestOutput
1444                               - key: ReceiveSubscriptionState
1445                                 value:
1446                                   stateKey:
1447                                     parentKeyName: ReceiveEventPolicy
1448                                     parentKeyVersion: 0.0.1
1449                                     parentLocalName: 'NULL'
1450                                     localName: ReceiveSubscriptionState
1451                                   trigger:
1452                                     name: pmsh-operational-policy
1453                                     version: 0.0.1
1454                                   stateOutputs:
1455                                     entry:
1456                                       - key: ReceivePMSubscriptionOutput
1457                                         value:
1458                                           key:
1459                                             parentKeyName: ReceiveEventPolicy
1460                                             parentKeyVersion: 0.0.1
1461                                             parentLocalName: ReceiveSubscriptionState
1462                                             localName: ReceivePMSubscriptionOutput
1463                                           outgoingEvent:
1464                                             name: PMSubscriptionOutputEvent
1465                                             version: 0.0.1
1466                                           outgoingEventReference:
1467                                             - name: PMSubscriptionOutputEvent
1468                                               version: 0.0.1
1469                                           nextState:
1470                                             parentKeyName: ReceiveEventPolicy
1471                                             parentKeyVersion: 0.0.1
1472                                             parentLocalName: 'NULL'
1473                                             localName: CreateOrDeleteState
1474                                   contextAlbumReference:
1475                                     - name: PMSubscriptionAlbum
1476                                       version: 0.0.1
1477                                   taskSelectionLogic:
1478                                     key: 'NULL'
1479                                     logicFlavour: UNDEFINED
1480                                     logic: ''
1481                                   stateFinalizerLogicMap:
1482                                     entry: [ ]
1483                                   defaultTask:
1484                                     name: ReceiveSubscriptionTask
1485                                     version: 0.0.1
1486                                   taskReferences:
1487                                     entry:
1488                                       - key:
1489                                           name: ReceiveSubscriptionTask
1490                                           version: 0.0.1
1491                                         value:
1492                                           key:
1493                                             parentKeyName: ReceiveEventPolicy
1494                                             parentKeyVersion: 0.0.1
1495                                             parentLocalName: ReceiveSubscriptionState
1496                                             localName: ReceiveEventPolicy
1497                                           outputType: DIRECT
1498                                           output:
1499                                             parentKeyName: ReceiveEventPolicy
1500                                             parentKeyVersion: 0.0.1
1501                                             parentLocalName: ReceiveSubscriptionState
1502                                             localName: ReceivePMSubscriptionOutput
1503                           firstState: ReceiveSubscriptionState
1504                 tasks:
1505                   key:
1506                     name: PMControlPolicy_Tasks
1507                     version: 0.0.1
1508                   taskMap:
1509                     entry:
1510                       - key:
1511                           name: CDSCreateResponseTask
1512                           version: 0.0.1
1513                         value:
1514                           key:
1515                             name: CDSCreateResponseTask
1516                             version: 0.0.1
1517                           inputEvent:
1518                             key:
1519                               name: CDSCreateResponseEvent
1520                               version: 0.0.1
1521                             nameSpace: org.onap.policy.apex.onap.pmcontrol
1522                             source: CDS
1523                             target: APEX
1524                             parameter:
1525                               entry:
1526                                 - key: actionIdentifiers
1527                                   value:
1528                                     key: actionIdentifiers
1529                                     fieldSchemaKey:
1530                                       name: CDSActionIdentifiersType
1531                                       version: 0.0.1
1532                                     optional: false
1533                                 - key: commonHeader
1534                                   value:
1535                                     key: commonHeader
1536                                     fieldSchemaKey:
1537                                       name: CDSResponseCommonHeaderType
1538                                       version: 0.0.1
1539                                     optional: false
1540                                 - key: payload
1541                                   value:
1542                                     key: payload
1543                                     fieldSchemaKey:
1544                                       name: CDSCreateResponsePayloadType
1545                                       version: 0.0.1
1546                                     optional: false
1547                                 - key: status
1548                                   value:
1549                                     key: status
1550                                     fieldSchemaKey:
1551                                       name: CDSResponseStatusType
1552                                       version: 0.0.1
1553                                     optional: false
1554                           outputEvents:
1555                             entry:
1556                               - key: CDSResponseStatusEvent
1557                                 value:
1558                                   key:
1559                                     name: CDSResponseStatusEvent
1560                                     version: 0.0.1
1561                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
1562                                   source: APEX
1563                                   target: DCAE
1564                                   parameter:
1565                                     entry:
1566                                       - key: status
1567                                         value:
1568                                           key: status
1569                                           fieldSchemaKey:
1570                                             name: SubscriptionStatusType
1571                                             version: 0.0.1
1572                                           optional: false
1573                           taskParameters:
1574                             entry: [ ]
1575                           contextAlbumReference:
1576                             - name: PMSubscriptionAlbum
1577                               version: 0.0.1
1578                           taskLogic:
1579                             key: TaskLogic
1580                             logicFlavour: JAVASCRIPT
1581                             logic: |-
1582                               /*
1583                                * ============LICENSE_START=======================================================
1584                                *  Copyright (C) 2020 Nordix. All rights reserved.
1585                                * ================================================================================
1586                                * Licensed under the Apache License, Version 2.0 (the "License");
1587                                * you may not use this file except in compliance with the License.
1588                                * You may obtain a copy of the License at
1589                                *
1590                                *      http://www.apache.org/licenses/LICENSE-2.0
1591                                *
1592                                * Unless required by applicable law or agreed to in writing, software
1593                                * distributed under the License is distributed on an "AS IS" BASIS,
1594                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1595                                * See the License for the specific language governing permissions and
1596                                * limitations under the License.
1597                                *
1598                                * SPDX-License-Identifier: Apache-2.0
1599                                * ============LICENSE_END=========================================================
1600                                */
1601                               executor.logger.info(executor.subject.id);
1602                               var commonHeader = executor.inFields.get("commonHeader")
1603                               var response = executor.inFields.get("payload")
1604                               var albumID = commonHeader.get("requestId")
1605                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(albumID.toString());
1606                               var responseStatus = executor.subject.getOutFieldSchemaHelper("status").createNewInstance();
1607                               var changeType = pmSubscriptionInfo.get("changeType").toUpperCase()
1608                               responseStatus.put("nfName", pmSubscriptionInfo.get("nfName"))
1609                               responseStatus.put("changeType", pmSubscriptionInfo.get("changeType"))
1610                               if ("CREATE".equals(changeType)) {
1611                                   responseStatus.put("subscriptionName", pmSubscriptionInfo.get("subscription").get("subscriptionName"))
1612                                   responseStatus.put("measurementGroupName", pmSubscriptionInfo.get("subscription").get("measurementGroup").get("measurementGroupName"))
1613                               }
1614                               else if ("DELETE".equals(changeType)) {
1615                                   responseStatus.put("subscriptionName", pmSubscriptionInfo.get("subscriptionName"))
1616                                   responseStatus.put("measurementGroupName", pmSubscriptionInfo.get("measurementGroupName"))
1617                               }
1618                               var status = response.get(pmSubscriptionInfo.get("changeType").toLowerCase() + "_DasH_subscription_DasH_response").get("odl_DasH_response").get("status")
1619                               executor.logger.info("RESPONSE STATUS = " + status)
1620                               if(status == "success") {
1621                                   responseStatus.put("message", "success")
1622                               } else {
1623                                   responseStatus.put("message", "failed")
1624                               }
1625                               executor.outFields.put("status", responseStatus)
1626                               returnValue = executor.isTrue;
1627                               true;
1628                       - key:
1629                           name: CDSDeleteResponseTask
1630                           version: 0.0.1
1631                         value:
1632                           key:
1633                             name: CDSDeleteResponseTask
1634                             version: 0.0.1
1635                           inputEvent:
1636                             key:
1637                               name: CDSDeleteResponseEvent
1638                               version: 0.0.1
1639                             nameSpace: org.onap.policy.apex.onap.pmcontrol
1640                             source: CDS
1641                             target: APEX
1642                             parameter:
1643                               entry:
1644                                 - key: actionIdentifiers
1645                                   value:
1646                                     key: actionIdentifiers
1647                                     fieldSchemaKey:
1648                                       name: CDSActionIdentifiersType
1649                                       version: 0.0.1
1650                                     optional: false
1651                                 - key: commonHeader
1652                                   value:
1653                                     key: commonHeader
1654                                     fieldSchemaKey:
1655                                       name: CDSResponseCommonHeaderType
1656                                       version: 0.0.1
1657                                     optional: false
1658                                 - key: payload
1659                                   value:
1660                                     key: payload
1661                                     fieldSchemaKey:
1662                                       name: CDSDeleteResponsePayloadType
1663                                       version: 0.0.1
1664                                     optional: false
1665                                 - key: status
1666                                   value:
1667                                     key: status
1668                                     fieldSchemaKey:
1669                                       name: CDSResponseStatusType
1670                                       version: 0.0.1
1671                                     optional: false
1672                           outputEvents:
1673                             entry:
1674                               - key: CDSResponseStatusEvent
1675                                 value:
1676                                   key:
1677                                     name: CDSResponseStatusEvent
1678                                     version: 0.0.1
1679                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
1680                                   source: APEX
1681                                   target: DCAE
1682                                   parameter:
1683                                     entry:
1684                                       - key: status
1685                                         value:
1686                                           key: status
1687                                           fieldSchemaKey:
1688                                             name: SubscriptionStatusType
1689                                             version: 0.0.1
1690                                           optional: false
1691                           taskParameters:
1692                             entry: [ ]
1693                           contextAlbumReference:
1694                             - name: PMSubscriptionAlbum
1695                               version: 0.0.1
1696                           taskLogic:
1697                             key: TaskLogic
1698                             logicFlavour: JAVASCRIPT
1699                             logic: |-
1700                               /*
1701                                * ============LICENSE_START=======================================================
1702                                *  Copyright (C) 2020 Nordix. All rights reserved.
1703                                * ================================================================================
1704                                * Licensed under the Apache License, Version 2.0 (the "License");
1705                                * you may not use this file except in compliance with the License.
1706                                * You may obtain a copy of the License at
1707                                *
1708                                *      http://www.apache.org/licenses/LICENSE-2.0
1709                                *
1710                                * Unless required by applicable law or agreed to in writing, software
1711                                * distributed under the License is distributed on an "AS IS" BASIS,
1712                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1713                                * See the License for the specific language governing permissions and
1714                                * limitations under the License.
1715                                *
1716                                * SPDX-License-Identifier: Apache-2.0
1717                                * ============LICENSE_END=========================================================
1718                                */
1719                               executor.logger.info(executor.subject.id);
1720                               var commonHeader = executor.inFields.get("commonHeader")
1721                               var response = executor.inFields.get("payload")
1722                               var albumID = commonHeader.get("requestId")
1723                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(albumID.toString());
1724                               var responseStatus = executor.subject.getOutFieldSchemaHelper("status").createNewInstance();
1725                               var changeType = pmSubscriptionInfo.get("changeType").toUpperCase()
1726                               responseStatus.put("nfName", pmSubscriptionInfo.get("nfName"))
1727                               responseStatus.put("changeType", pmSubscriptionInfo.get("changeType"))
1728                               if ("CREATE".equals(changeType)) {
1729                                   responseStatus.put("subscriptionName", pmSubscriptionInfo.get("subscription").get("subscriptionName"))
1730                                   responseStatus.put("measurementGroupName", pmSubscriptionInfo.get("subscription").get("measurementGroup").get("measurementGroupName"))
1731                               }
1732                               else if ("DELETE".equals(changeType)) {
1733                                   responseStatus.put("subscriptionName", pmSubscriptionInfo.get("subscriptionName"))
1734                                   responseStatus.put("measurementGroupName", pmSubscriptionInfo.get("measurementGroupName"))
1735                               }
1736                               var status = response.get(pmSubscriptionInfo.get("changeType").toLowerCase() + "_DasH_subscription_DasH_response").get("odl_DasH_response").get("status")
1737                               executor.logger.info("RESPONSE STATUS = " + status)
1738                               if(status == "success") {
1739                                   responseStatus.put("message", "success")
1740                               } else {
1741                                   responseStatus.put("message", "failed")
1742                               }
1743                               executor.outFields.put("status", responseStatus)
1744                               returnValue = executor.isTrue;
1745                               true;
1746                       - key:
1747                           name: CreateSubscriptionPayloadTask
1748                           version: 0.0.1
1749                         value:
1750                           key:
1751                             name: CreateSubscriptionPayloadTask
1752                             version: 0.0.1
1753                           inputEvent:
1754                             key:
1755                               name: PMSubscriptionOutputEvent
1756                               version: 0.0.1
1757                             nameSpace: org.onap.policy.apex.onap.pmcontrol
1758                             source: APEX
1759                             target: APEX
1760                             parameter:
1761                               entry:
1762                                 - key: albumID
1763                                   value:
1764                                     key: albumID
1765                                     fieldSchemaKey:
1766                                       name: UUIDType
1767                                       version: 0.0.1
1768                                     optional: false
1769                           outputEvents:
1770                             entry:
1771                               - key: CreateSubscriptionPayloadEvent
1772                                 value:
1773                                   key:
1774                                     name: CreateSubscriptionPayloadEvent
1775                                     version: 0.0.1
1776                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
1777                                   source: APEX
1778                                   target: APEX
1779                                   parameter:
1780                                     entry:
1781                                       - key: albumID
1782                                         value:
1783                                           key: albumID
1784                                           fieldSchemaKey:
1785                                             name: UUIDType
1786                                             version: 0.0.1
1787                                           optional: false
1788                                       - key: payload
1789                                         value:
1790                                           key: payload
1791                                           fieldSchemaKey:
1792                                             name: CDSCreateSubscriptionPayloadType
1793                                             version: 0.0.1
1794                                           optional: false
1795                           taskParameters:
1796                             entry: [ ]
1797                           contextAlbumReference:
1798                             - name: PMSubscriptionAlbum
1799                               version: 0.0.1
1800                           taskLogic:
1801                             key: TaskLogic
1802                             logicFlavour: JAVASCRIPT
1803                             logic: |-
1804                               /*
1805                                * ============LICENSE_START=======================================================
1806                                *  Copyright (C) 2020 Nordix. All rights reserved.
1807                                * ================================================================================
1808                                * Licensed under the Apache License, Version 2.0 (the "License");
1809                                * you may not use this file except in compliance with the License.
1810                                * You may obtain a copy of the License at
1811                                *
1812                                *      http://www.apache.org/licenses/LICENSE-2.0
1813                                *
1814                                * Unless required by applicable law or agreed to in writing, software
1815                                * distributed under the License is distributed on an "AS IS" BASIS,
1816                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1817                                * See the License for the specific language governing permissions and
1818                                * limitations under the License.
1819                                *
1820                                * SPDX-License-Identifier: Apache-2.0
1821                                * ============LICENSE_END=========================================================
1822                                */
1823                               executor.logger.info(executor.subject.id);
1824                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(executor.inFields.get("albumID").toString())
1825                               var changeType = pmSubscriptionInfo.get("changeType").toLowerCase()
1826                               var payloadProperties = executor.subject.getOutFieldSchemaHelper("payload").createNewSubInstance(changeType + "_DasH_subscription_DasH_properties_record");
1827                               payloadProperties.put("nfName",  pmSubscriptionInfo.get("nfName"))
1828                               payloadProperties.put("ipAddress", pmSubscriptionInfo.get("ipAddress"))
1829                               if ("create".equals(changeType)) {
1830                                   payloadProperties.put("subscriptionName",  pmSubscriptionInfo.get("subscription").get("subscriptionName"))
1831                                   payloadProperties.put("fileBasedGP",  pmSubscriptionInfo.get("subscription").get("fileBasedGP").toString())
1832                                   payloadProperties.put("fileLocation", pmSubscriptionInfo.get("subscription").get("fileLocation"))
1833                                   payloadProperties.put("measurementGroup", pmSubscriptionInfo.get("subscription").get("measurementGroup"))
1834                               }
1835                               else if ("delete".equals(changeType)) {
1836                                   payloadProperties.put("subscriptionName", pmSubscriptionInfo.get("subscriptionName"))
1837                                   payloadProperties.put("measurementGroupName", pmSubscriptionInfo.get("measurementGroupName"))
1838                               }
1839                               var payloadEntry = executor.subject.getOutFieldSchemaHelper("payload").createNewSubInstance("CDSRequestPayloadEntry");
1840                               payloadEntry.put(changeType + "_DasH_subscription_DasH_properties", payloadProperties)
1841                               var payload = executor.subject.getOutFieldSchemaHelper("payload").createNewInstance();
1842                               payload.put(changeType + "_DasH_subscription_DasH_request", payloadEntry);
1843                               executor.outFields.put("albumID", executor.inFields.get("albumID"))
1844                               executor.outFields.put("payload", payload);
1845                               returnValue = executor.isTrue;
1846                               true;
1847                       - key:
1848                           name: CreateSubscriptionRequestTask
1849                           version: 0.0.1
1850                         value:
1851                           key:
1852                             name: CreateSubscriptionRequestTask
1853                             version: 0.0.1
1854                           inputEvent:
1855                             key:
1856                               name: CreateSubscriptionPayloadEvent
1857                               version: 0.0.1
1858                             nameSpace: org.onap.policy.apex.onap.pmcontrol
1859                             source: APEX
1860                             target: APEX
1861                             parameter:
1862                               entry:
1863                                 - key: albumID
1864                                   value:
1865                                     key: albumID
1866                                     fieldSchemaKey:
1867                                       name: UUIDType
1868                                       version: 0.0.1
1869                                     optional: false
1870                                 - key: payload
1871                                   value:
1872                                     key: payload
1873                                     fieldSchemaKey:
1874                                       name: CDSCreateSubscriptionPayloadType
1875                                       version: 0.0.1
1876                                     optional: false
1877                           outputEvents:
1878                             entry:
1879                               - key: CDSCreateSubscriptionRequestEvent
1880                                 value:
1881                                   key:
1882                                     name: CDSCreateSubscriptionRequestEvent
1883                                     version: 0.0.1
1884                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
1885                                   source: APEX
1886                                   target: APEX
1887                                   parameter:
1888                                     entry:
1889                                       - key: actionIdentifiers
1890                                         value:
1891                                           key: actionIdentifiers
1892                                           fieldSchemaKey:
1893                                             name: CDSActionIdentifiersType
1894                                             version: 0.0.1
1895                                           optional: false
1896                                       - key: commonHeader
1897                                         value:
1898                                           key: commonHeader
1899                                           fieldSchemaKey:
1900                                             name: CDSRequestCommonHeaderType
1901                                             version: 0.0.1
1902                                           optional: false
1903                                       - key: payload
1904                                         value:
1905                                           key: payload
1906                                           fieldSchemaKey:
1907                                             name: CDSCreateSubscriptionPayloadType
1908                                             version: 0.0.1
1909                                           optional: false
1910                           taskParameters:
1911                             entry: [ ]
1912                           contextAlbumReference:
1913                             - name: PMSubscriptionAlbum
1914                               version: 0.0.1
1915                           taskLogic:
1916                             key: TaskLogic
1917                             logicFlavour: JAVASCRIPT
1918                             logic: |-
1919                               /*
1920                                * ============LICENSE_START=======================================================
1921                                *  Copyright (C) 2020 Nordix. All rights reserved.
1922                                * ================================================================================
1923                                * Licensed under the Apache License, Version 2.0 (the "License");
1924                                * you may not use this file except in compliance with the License.
1925                                * You may obtain a copy of the License at
1926                                *
1927                                *      http://www.apache.org/licenses/LICENSE-2.0
1928                                *
1929                                * Unless required by applicable law or agreed to in writing, software
1930                                * distributed under the License is distributed on an "AS IS" BASIS,
1931                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1932                                * See the License for the specific language governing permissions and
1933                                * limitations under the License.
1934                                *
1935                                * SPDX-License-Identifier: Apache-2.0
1936                                * ============LICENSE_END=========================================================
1937                                */
1938                               executor.logger.info(executor.subject.id);
1939                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(executor.inFields.get("albumID").toString())
1940                               executor.logger.info(pmSubscriptionInfo)
1941                               var changeType = pmSubscriptionInfo.get("changeType").toLowerCase()
1942                               var blueprintName = pmSubscriptionInfo.get("blueprintName").toLowerCase()
1943                               var blueprintVersion = pmSubscriptionInfo.get("blueprintVersion").toLowerCase()
1944                               var payload = executor.inFields.get("payload")
1945                               var actionName = changeType + "-subscription"
1946                               var commonHeader = executor.subject.getOutFieldSchemaHelper("commonHeader").createNewInstance();
1947                               commonHeader.put("originatorId", "sdnc");
1948                               commonHeader.put("requestId", executor.inFields.get("albumID").toString());
1949                               commonHeader.put("subRequestId", "sub-123456-1000");
1950                               var actionIdentifiers = executor.subject.getOutFieldSchemaHelper("actionIdentifiers").createNewInstance();
1951                               actionIdentifiers.put("actionName", actionName);
1952                               actionIdentifiers.put("blueprintName", blueprintName);
1953                               actionIdentifiers.put("blueprintVersion", blueprintVersion);
1954                               actionIdentifiers.put("mode", "sync");
1955                               executor.outFields.put("commonHeader", commonHeader);
1956                               executor.outFields.put("actionIdentifiers", actionIdentifiers);
1957                               executor.outFields.put("payload", payload);
1958                               returnValue = executor.isTrue;
1959                               true;
1960                       - key:
1961                           name: DeleteSubscriptionPayloadTask
1962                           version: 0.0.1
1963                         value:
1964                           key:
1965                             name: DeleteSubscriptionPayloadTask
1966                             version: 0.0.1
1967                           inputEvent:
1968                             key:
1969                               name: PMSubscriptionOutputEvent
1970                               version: 0.0.1
1971                             nameSpace: org.onap.policy.apex.onap.pmcontrol
1972                             source: APEX
1973                             target: APEX
1974                             parameter:
1975                               entry:
1976                                 - key: albumID
1977                                   value:
1978                                     key: albumID
1979                                     fieldSchemaKey:
1980                                       name: UUIDType
1981                                       version: 0.0.1
1982                                     optional: false
1983                           outputEvents:
1984                             entry:
1985                               - key: DeleteSubscriptionPayloadEvent
1986                                 value:
1987                                   key:
1988                                     name: DeleteSubscriptionPayloadEvent
1989                                     version: 0.0.1
1990                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
1991                                   source: APEX
1992                                   target: APEX
1993                                   parameter:
1994                                     entry:
1995                                       - key: albumID
1996                                         value:
1997                                           key: albumID
1998                                           fieldSchemaKey:
1999                                             name: UUIDType
2000                                             version: 0.0.1
2001                                           optional: false
2002                                       - key: payload
2003                                         value:
2004                                           key: payload
2005                                           fieldSchemaKey:
2006                                             name: CDSDeleteSubscriptionPayloadType
2007                                             version: 0.0.1
2008                                           optional: false
2009                           taskParameters:
2010                             entry: [ ]
2011                           contextAlbumReference:
2012                             - name: PMSubscriptionAlbum
2013                               version: 0.0.1
2014                           taskLogic:
2015                             key: TaskLogic
2016                             logicFlavour: JAVASCRIPT
2017                             logic: |-
2018                               /*
2019                                * ============LICENSE_START=======================================================
2020                                *  Copyright (C) 2020 Nordix. All rights reserved.
2021                                * ================================================================================
2022                                * Licensed under the Apache License, Version 2.0 (the "License");
2023                                * you may not use this file except in compliance with the License.
2024                                * You may obtain a copy of the License at
2025                                *
2026                                *      http://www.apache.org/licenses/LICENSE-2.0
2027                                *
2028                                * Unless required by applicable law or agreed to in writing, software
2029                                * distributed under the License is distributed on an "AS IS" BASIS,
2030                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
2031                                * See the License for the specific language governing permissions and
2032                                * limitations under the License.
2033                                *
2034                                * SPDX-License-Identifier: Apache-2.0
2035                                * ============LICENSE_END=========================================================
2036                                */
2037                               executor.logger.info(executor.subject.id);
2038                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(executor.inFields.get("albumID").toString())
2039                               var changeType = pmSubscriptionInfo.get("changeType").toLowerCase()
2040                               var payloadProperties = executor.subject.getOutFieldSchemaHelper("payload").createNewSubInstance(changeType + "_DasH_subscription_DasH_properties_record");
2041                               payloadProperties.put("nfName",  pmSubscriptionInfo.get("nfName"))
2042                               payloadProperties.put("ipAddress", pmSubscriptionInfo.get("ipAddress"))
2043                               if ("create".equals(changeType)) {
2044                                   payloadProperties.put("subscriptionName",  pmSubscriptionInfo.get("subscription").get("subscriptionName"))
2045                                   payloadProperties.put("fileBasedGP",  pmSubscriptionInfo.get("subscription").get("fileBasedGP").toString())
2046                                   payloadProperties.put("fileLocation", pmSubscriptionInfo.get("subscription").get("fileLocation"))
2047                                   payloadProperties.put("measurementGroup", pmSubscriptionInfo.get("subscription").get("measurementGroup"))
2048                               }
2049                               else if ("delete".equals(changeType)) {
2050                                   payloadProperties.put("subscriptionName", pmSubscriptionInfo.get("subscriptionName"))
2051                                   payloadProperties.put("measurementGroupName", pmSubscriptionInfo.get("measurementGroupName"))
2052                               }
2053                               var payloadEntry = executor.subject.getOutFieldSchemaHelper("payload").createNewSubInstance("CDSRequestPayloadEntry");
2054                               payloadEntry.put(changeType + "_DasH_subscription_DasH_properties", payloadProperties)
2055                               var payload = executor.subject.getOutFieldSchemaHelper("payload").createNewInstance();
2056                               payload.put(changeType + "_DasH_subscription_DasH_request", payloadEntry);
2057                               executor.outFields.put("albumID", executor.inFields.get("albumID"))
2058                               executor.outFields.put("payload", payload);
2059                               returnValue = executor.isTrue;
2060                               true;
2061                       - key:
2062                           name: DeleteSubscriptionRequestTask
2063                           version: 0.0.1
2064                         value:
2065                           key:
2066                             name: DeleteSubscriptionRequestTask
2067                             version: 0.0.1
2068                           inputEvent:
2069                             key:
2070                               name: DeleteSubscriptionPayloadEvent
2071                               version: 0.0.1
2072                             nameSpace: org.onap.policy.apex.onap.pmcontrol
2073                             source: APEX
2074                             target: APEX
2075                             parameter:
2076                               entry:
2077                                 - key: albumID
2078                                   value:
2079                                     key: albumID
2080                                     fieldSchemaKey:
2081                                       name: UUIDType
2082                                       version: 0.0.1
2083                                     optional: false
2084                                 - key: payload
2085                                   value:
2086                                     key: payload
2087                                     fieldSchemaKey:
2088                                       name: CDSDeleteSubscriptionPayloadType
2089                                       version: 0.0.1
2090                                     optional: false
2091                           outputEvents:
2092                             entry:
2093                               - key: CDSDeleteSubscriptionRequestEvent
2094                                 value:
2095                                   key:
2096                                     name: CDSDeleteSubscriptionRequestEvent
2097                                     version: 0.0.1
2098                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
2099                                   source: APEX
2100                                   target: APEX
2101                                   parameter:
2102                                     entry:
2103                                       - key: actionIdentifiers
2104                                         value:
2105                                           key: actionIdentifiers
2106                                           fieldSchemaKey:
2107                                             name: CDSActionIdentifiersType
2108                                             version: 0.0.1
2109                                           optional: false
2110                                       - key: commonHeader
2111                                         value:
2112                                           key: commonHeader
2113                                           fieldSchemaKey:
2114                                             name: CDSRequestCommonHeaderType
2115                                             version: 0.0.1
2116                                           optional: false
2117                                       - key: payload
2118                                         value:
2119                                           key: payload
2120                                           fieldSchemaKey:
2121                                             name: CDSDeleteSubscriptionPayloadType
2122                                             version: 0.0.1
2123                                           optional: false
2124                           taskParameters:
2125                             entry: [ ]
2126                           contextAlbumReference:
2127                             - name: PMSubscriptionAlbum
2128                               version: 0.0.1
2129                           taskLogic:
2130                             key: TaskLogic
2131                             logicFlavour: JAVASCRIPT
2132                             logic: |-
2133                               /*
2134                                * ============LICENSE_START=======================================================
2135                                *  Copyright (C) 2020 Nordix. All rights reserved.
2136                                * ================================================================================
2137                                * Licensed under the Apache License, Version 2.0 (the "License");
2138                                * you may not use this file except in compliance with the License.
2139                                * You may obtain a copy of the License at
2140                                *
2141                                *      http://www.apache.org/licenses/LICENSE-2.0
2142                                *
2143                                * Unless required by applicable law or agreed to in writing, software
2144                                * distributed under the License is distributed on an "AS IS" BASIS,
2145                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
2146                                * See the License for the specific language governing permissions and
2147                                * limitations under the License.
2148                                *
2149                                * SPDX-License-Identifier: Apache-2.0
2150                                * ============LICENSE_END=========================================================
2151                                */
2152                               executor.logger.info(executor.subject.id);
2153                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").get(executor.inFields.get("albumID").toString())
2154                               executor.logger.info(pmSubscriptionInfo)
2155                               var changeType = pmSubscriptionInfo.get("changeType").toLowerCase()
2156                               var blueprintName = pmSubscriptionInfo.get("blueprintName").toLowerCase()
2157                               var blueprintVersion = pmSubscriptionInfo.get("blueprintVersion").toLowerCase()
2158                               var payload = executor.inFields.get("payload")
2159                               var actionName = changeType + "-subscription"
2160                               var commonHeader = executor.subject.getOutFieldSchemaHelper("commonHeader").createNewInstance();
2161                               commonHeader.put("originatorId", "sdnc");
2162                               commonHeader.put("requestId", executor.inFields.get("albumID").toString());
2163                               commonHeader.put("subRequestId", "sub-123456-1000");
2164                               var actionIdentifiers = executor.subject.getOutFieldSchemaHelper("actionIdentifiers").createNewInstance();
2165                               actionIdentifiers.put("actionName", actionName);
2166                               actionIdentifiers.put("blueprintName", blueprintName);
2167                               actionIdentifiers.put("blueprintVersion", blueprintVersion);
2168                               actionIdentifiers.put("mode", "sync");
2169                               executor.outFields.put("commonHeader", commonHeader);
2170                               executor.outFields.put("actionIdentifiers", actionIdentifiers);
2171                               executor.outFields.put("payload", payload);
2172                               returnValue = executor.isTrue;
2173                               true;
2174                       - key:
2175                           name: ReceiveSubscriptionTask
2176                           version: 0.0.1
2177                         value:
2178                           key:
2179                             name: ReceiveSubscriptionTask
2180                             version: 0.0.1
2181                           inputEvent:
2182                             key:
2183                               name: pmsh-operational-policy
2184                               version: 0.0.1
2185                             nameSpace: org.onap.policy.apex.onap.pmcontrol
2186                             source: DCAE
2187                             target: APEX
2188                             parameter:
2189                               entry:
2190                                 - key: blueprintName
2191                                   value:
2192                                     key: blueprintName
2193                                     fieldSchemaKey:
2194                                       name: SimpleStringType
2195                                       version: 0.0.1
2196                                     optional: false
2197                                 - key: blueprintVersion
2198                                   value:
2199                                     key: blueprintVersion
2200                                     fieldSchemaKey:
2201                                       name: SimpleStringType
2202                                       version: 0.0.1
2203                                     optional: false
2204                                 - key: changeType
2205                                   value:
2206                                     key: changeType
2207                                     fieldSchemaKey:
2208                                       name: SimpleStringType
2209                                       version: 0.0.1
2210                                     optional: false
2211                                 - key: controlLoopName
2212                                   value:
2213                                     key: controlLoopName
2214                                     fieldSchemaKey:
2215                                       name: SimpleStringType
2216                                       version: 0.0.1
2217                                     optional: false
2218                                 - key: ipAddress
2219                                   value:
2220                                     key: ipAddress
2221                                     fieldSchemaKey:
2222                                       name: SimpleStringType
2223                                       version: 0.0.1
2224                                     optional: false
2225                                 - key: measurementGroupName
2226                                   value:
2227                                     key: measurementGroupName
2228                                     fieldSchemaKey:
2229                                       name: SimpleStringType
2230                                       version: 0.0.1
2231                                     optional: true
2232                                 - key: nfName
2233                                   value:
2234                                     key: nfName
2235                                     fieldSchemaKey:
2236                                       name: SimpleStringType
2237                                       version: 0.0.1
2238                                     optional: false
2239                                 - key: operationalPolicyName
2240                                   value:
2241                                     key: operationalPolicyName
2242                                     fieldSchemaKey:
2243                                       name: SimpleStringType
2244                                       version: 0.0.1
2245                                     optional: false
2246                                 - key: subscription
2247                                   value:
2248                                     key: subscription
2249                                     fieldSchemaKey:
2250                                       name: SubscriptionType
2251                                       version: 0.0.1
2252                                     optional: true
2253                                 - key: subscriptionName
2254                                   value:
2255                                     key: subscriptionName
2256                                     fieldSchemaKey:
2257                                       name: SimpleStringType
2258                                       version: 0.0.1
2259                                     optional: true
2260                           outputEvents:
2261                             entry:
2262                               - key: PMSubscriptionOutputEvent
2263                                 value:
2264                                   key:
2265                                     name: PMSubscriptionOutputEvent
2266                                     version: 0.0.1
2267                                   nameSpace: org.onap.policy.apex.onap.pmcontrol
2268                                   source: APEX
2269                                   target: APEX
2270                                   parameter:
2271                                     entry:
2272                                       - key: albumID
2273                                         value:
2274                                           key: albumID
2275                                           fieldSchemaKey:
2276                                             name: UUIDType
2277                                             version: 0.0.1
2278                                           optional: false
2279                           taskParameters:
2280                             entry: [ ]
2281                           contextAlbumReference:
2282                             - name: PMSubscriptionAlbum
2283                               version: 0.0.1
2284                           taskLogic:
2285                             key: TaskLogic
2286                             logicFlavour: JAVASCRIPT
2287                             logic: |-
2288                               /*
2289                                * ============LICENSE_START=======================================================
2290                                *  Copyright (C) 2020 Nordix. All rights reserved.
2291                                * ================================================================================
2292                                * Licensed under the Apache License, Version 2.0 (the "License");
2293                                * you may not use this file except in compliance with the License.
2294                                * You may obtain a copy of the License at
2295                                *
2296                                *      http://www.apache.org/licenses/LICENSE-2.0
2297                                *
2298                                * Unless required by applicable law or agreed to in writing, software
2299                                * distributed under the License is distributed on an "AS IS" BASIS,
2300                                * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
2301                                * See the License for the specific language governing permissions and
2302                                * limitations under the License.
2303                                *
2304                                * SPDX-License-Identifier: Apache-2.0
2305                                * ============LICENSE_END=========================================================
2306                                */
2307                               var uuidType = java.util.UUID;
2308                               executor.logger.info(executor.subject.id);
2309                               //albumID will be used to fetch info from our album later
2310                               var albumID = uuidType.randomUUID();
2311                               var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").getSchemaHelper().createNewInstance();
2312                               var returnValue = true;
2313                               if(executor.inFields.get("operationalPolicyName") != null) {
2314                                   executor.logger.info("nfName in receive sub event " + executor.inFields.get("nfName"));
2315                                   var changeType = executor.inFields.get("changeType")
2316                                   var nfName = executor.inFields.get("nfName")
2317                                   var ipAddress = executor.inFields.get("ipAddress")
2318                                   var operationalPolicyName = executor.inFields.get("operationalPolicyName")
2319                                   var controlLoopName = executor.inFields.get("controlLoopName")
2320                                   var subscription = executor.inFields.get("subscription")
2321                                   var blueprintName = executor.inFields.get("blueprintName")
2322                                   var blueprintVersion = executor.inFields.get("blueprintVersion")
2323                                   pmSubscriptionInfo.put("nfName", executor.inFields.get("nfName"));
2324                                   pmSubscriptionInfo.put("ipAddress", executor.inFields.get("ipAddress"));
2325                                   pmSubscriptionInfo.put("changeType", executor.inFields.get("changeType"))
2326                                   pmSubscriptionInfo.put("operationalPolicyName", executor.inFields.get("operationalPolicyName"))
2327                                   pmSubscriptionInfo.put("controlLoopName", executor.inFields.get("controlLoopName"))
2328                                   pmSubscriptionInfo.put("subscription", subscription)
2329                                   pmSubscriptionInfo.put("blueprintName", blueprintName)
2330                                   pmSubscriptionInfo.put("blueprintVersion", blueprintVersion)
2331                                   if ("delete".equals(changeType.toLowerCase())) {
2332                                       pmSubscriptionInfo.put("subscriptionName",  executor.inFields.get("subscriptionName"))
2333                                       pmSubscriptionInfo.put("measurementGroupName",  executor.inFields.get("measurementGroupName"))
2334                                   }
2335                                   executor.getContextAlbum("PMSubscriptionAlbum").put(albumID.toString(), pmSubscriptionInfo);
2336                                   executor.outFields.put("albumID", albumID)
2337                               } else {
2338                                   executor.message = "Received invalid event"
2339                                   returnValue = false;
2340                               }
2341                               returnValue;
2342                 events:
2343                   key:
2344                     name: PMControlPolicy_Events
2345                     version: 0.0.1
2346                   eventMap:
2347                     entry:
2348                       - key:
2349                           name: CDSCreateResponseEvent
2350                           version: 0.0.1
2351                         value:
2352                           key:
2353                             name: CDSCreateResponseEvent
2354                             version: 0.0.1
2355                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2356                           source: CDS
2357                           target: APEX
2358                           parameter:
2359                             entry:
2360                               - key: actionIdentifiers
2361                                 value:
2362                                   key: actionIdentifiers
2363                                   fieldSchemaKey:
2364                                     name: CDSActionIdentifiersType
2365                                     version: 0.0.1
2366                                   optional: false
2367                               - key: commonHeader
2368                                 value:
2369                                   key: commonHeader
2370                                   fieldSchemaKey:
2371                                     name: CDSResponseCommonHeaderType
2372                                     version: 0.0.1
2373                                   optional: false
2374                               - key: payload
2375                                 value:
2376                                   key: payload
2377                                   fieldSchemaKey:
2378                                     name: CDSCreateResponsePayloadType
2379                                     version: 0.0.1
2380                                   optional: false
2381                               - key: status
2382                                 value:
2383                                   key: status
2384                                   fieldSchemaKey:
2385                                     name: CDSResponseStatusType
2386                                     version: 0.0.1
2387                                   optional: false
2388                       - key:
2389                           name: CDSCreateSubscriptionRequestEvent
2390                           version: 0.0.1
2391                         value:
2392                           key:
2393                             name: CDSCreateSubscriptionRequestEvent
2394                             version: 0.0.1
2395                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2396                           source: APEX
2397                           target: APEX
2398                           parameter:
2399                             entry:
2400                               - key: actionIdentifiers
2401                                 value:
2402                                   key: actionIdentifiers
2403                                   fieldSchemaKey:
2404                                     name: CDSActionIdentifiersType
2405                                     version: 0.0.1
2406                                   optional: false
2407                               - key: commonHeader
2408                                 value:
2409                                   key: commonHeader
2410                                   fieldSchemaKey:
2411                                     name: CDSRequestCommonHeaderType
2412                                     version: 0.0.1
2413                                   optional: false
2414                               - key: payload
2415                                 value:
2416                                   key: payload
2417                                   fieldSchemaKey:
2418                                     name: CDSCreateSubscriptionPayloadType
2419                                     version: 0.0.1
2420                                   optional: false
2421                       - key:
2422                           name: CDSDeleteResponseEvent
2423                           version: 0.0.1
2424                         value:
2425                           key:
2426                             name: CDSDeleteResponseEvent
2427                             version: 0.0.1
2428                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2429                           source: CDS
2430                           target: APEX
2431                           parameter:
2432                             entry:
2433                               - key: actionIdentifiers
2434                                 value:
2435                                   key: actionIdentifiers
2436                                   fieldSchemaKey:
2437                                     name: CDSActionIdentifiersType
2438                                     version: 0.0.1
2439                                   optional: false
2440                               - key: commonHeader
2441                                 value:
2442                                   key: commonHeader
2443                                   fieldSchemaKey:
2444                                     name: CDSResponseCommonHeaderType
2445                                     version: 0.0.1
2446                                   optional: false
2447                               - key: payload
2448                                 value:
2449                                   key: payload
2450                                   fieldSchemaKey:
2451                                     name: CDSDeleteResponsePayloadType
2452                                     version: 0.0.1
2453                                   optional: false
2454                               - key: status
2455                                 value:
2456                                   key: status
2457                                   fieldSchemaKey:
2458                                     name: CDSResponseStatusType
2459                                     version: 0.0.1
2460                                   optional: false
2461                       - key:
2462                           name: CDSDeleteSubscriptionRequestEvent
2463                           version: 0.0.1
2464                         value:
2465                           key:
2466                             name: CDSDeleteSubscriptionRequestEvent
2467                             version: 0.0.1
2468                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2469                           source: APEX
2470                           target: APEX
2471                           parameter:
2472                             entry:
2473                               - key: actionIdentifiers
2474                                 value:
2475                                   key: actionIdentifiers
2476                                   fieldSchemaKey:
2477                                     name: CDSActionIdentifiersType
2478                                     version: 0.0.1
2479                                   optional: false
2480                               - key: commonHeader
2481                                 value:
2482                                   key: commonHeader
2483                                   fieldSchemaKey:
2484                                     name: CDSRequestCommonHeaderType
2485                                     version: 0.0.1
2486                                   optional: false
2487                               - key: payload
2488                                 value:
2489                                   key: payload
2490                                   fieldSchemaKey:
2491                                     name: CDSDeleteSubscriptionPayloadType
2492                                     version: 0.0.1
2493                                   optional: false
2494                       - key:
2495                           name: CDSResponseStatusEvent
2496                           version: 0.0.1
2497                         value:
2498                           key:
2499                             name: CDSResponseStatusEvent
2500                             version: 0.0.1
2501                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2502                           source: APEX
2503                           target: DCAE
2504                           parameter:
2505                             entry:
2506                               - key: status
2507                                 value:
2508                                   key: status
2509                                   fieldSchemaKey:
2510                                     name: SubscriptionStatusType
2511                                     version: 0.0.1
2512                                   optional: false
2513                       - key:
2514                           name: CreateSubscriptionPayloadEvent
2515                           version: 0.0.1
2516                         value:
2517                           key:
2518                             name: CreateSubscriptionPayloadEvent
2519                             version: 0.0.1
2520                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2521                           source: APEX
2522                           target: APEX
2523                           parameter:
2524                             entry:
2525                               - key: albumID
2526                                 value:
2527                                   key: albumID
2528                                   fieldSchemaKey:
2529                                     name: UUIDType
2530                                     version: 0.0.1
2531                                   optional: false
2532                               - key: payload
2533                                 value:
2534                                   key: payload
2535                                   fieldSchemaKey:
2536                                     name: CDSCreateSubscriptionPayloadType
2537                                     version: 0.0.1
2538                                   optional: false
2539                       - key:
2540                           name: DeleteSubscriptionPayloadEvent
2541                           version: 0.0.1
2542                         value:
2543                           key:
2544                             name: DeleteSubscriptionPayloadEvent
2545                             version: 0.0.1
2546                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2547                           source: APEX
2548                           target: APEX
2549                           parameter:
2550                             entry:
2551                               - key: albumID
2552                                 value:
2553                                   key: albumID
2554                                   fieldSchemaKey:
2555                                     name: UUIDType
2556                                     version: 0.0.1
2557                                   optional: false
2558                               - key: payload
2559                                 value:
2560                                   key: payload
2561                                   fieldSchemaKey:
2562                                     name: CDSDeleteSubscriptionPayloadType
2563                                     version: 0.0.1
2564                                   optional: false
2565                       - key:
2566                           name: MRResponseEvent
2567                           version: 0.0.1
2568                         value:
2569                           key:
2570                             name: MRResponseEvent
2571                             version: 0.0.1
2572                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2573                           source: DCAE
2574                           target: APEX
2575                           parameter:
2576                             entry:
2577                               - key: count
2578                                 value:
2579                                   key: count
2580                                   fieldSchemaKey:
2581                                     name: SimpleIntType
2582                                     version: 0.0.1
2583                                   optional: false
2584                               - key: serverTimeMs
2585                                 value:
2586                                   key: serverTimeMs
2587                                   fieldSchemaKey:
2588                                     name: SimpleIntType
2589                                     version: 0.0.1
2590                                   optional: false
2591                       - key:
2592                           name: PMSubscriptionOutputEvent
2593                           version: 0.0.1
2594                         value:
2595                           key:
2596                             name: PMSubscriptionOutputEvent
2597                             version: 0.0.1
2598                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2599                           source: APEX
2600                           target: APEX
2601                           parameter:
2602                             entry:
2603                               - key: albumID
2604                                 value:
2605                                   key: albumID
2606                                   fieldSchemaKey:
2607                                     name: UUIDType
2608                                     version: 0.0.1
2609                                   optional: false
2610                       - key:
2611                           name: pmsh-operational-policy
2612                           version: 0.0.1
2613                         value:
2614                           key:
2615                             name: pmsh-operational-policy
2616                             version: 0.0.1
2617                           nameSpace: org.onap.policy.apex.onap.pmcontrol
2618                           source: DCAE
2619                           target: APEX
2620                           parameter:
2621                             entry:
2622                               - key: blueprintName
2623                                 value:
2624                                   key: blueprintName
2625                                   fieldSchemaKey:
2626                                     name: SimpleStringType
2627                                     version: 0.0.1
2628                                   optional: false
2629                               - key: blueprintVersion
2630                                 value:
2631                                   key: blueprintVersion
2632                                   fieldSchemaKey:
2633                                     name: SimpleStringType
2634                                     version: 0.0.1
2635                                   optional: false
2636                               - key: changeType
2637                                 value:
2638                                   key: changeType
2639                                   fieldSchemaKey:
2640                                     name: SimpleStringType
2641                                     version: 0.0.1
2642                                   optional: false
2643                               - key: controlLoopName
2644                                 value:
2645                                   key: controlLoopName
2646                                   fieldSchemaKey:
2647                                     name: SimpleStringType
2648                                     version: 0.0.1
2649                                   optional: false
2650                               - key: ipAddress
2651                                 value:
2652                                   key: ipAddress
2653                                   fieldSchemaKey:
2654                                     name: SimpleStringType
2655                                     version: 0.0.1
2656                                   optional: false
2657                               - key: measurementGroupName
2658                                 value:
2659                                   key: measurementGroupName
2660                                   fieldSchemaKey:
2661                                     name: SimpleStringType
2662                                     version: 0.0.1
2663                                   optional: true
2664                               - key: nfName
2665                                 value:
2666                                   key: nfName
2667                                   fieldSchemaKey:
2668                                     name: SimpleStringType
2669                                     version: 0.0.1
2670                                   optional: false
2671                               - key: operationalPolicyName
2672                                 value:
2673                                   key: operationalPolicyName
2674                                   fieldSchemaKey:
2675                                     name: SimpleStringType
2676                                     version: 0.0.1
2677                                   optional: false
2678                               - key: subscription
2679                                 value:
2680                                   key: subscription
2681                                   fieldSchemaKey:
2682                                     name: SubscriptionType
2683                                     version: 0.0.1
2684                                   optional: true
2685                               - key: subscriptionName
2686                                 value:
2687                                   key: subscriptionName
2688                                   fieldSchemaKey:
2689                                     name: SimpleStringType
2690                                     version: 0.0.1
2691                                   optional: true
2692                 albums:
2693                   key:
2694                     name: PMControlPolicy_Albums
2695                     version: 0.0.1
2696                   albums:
2697                     entry:
2698                       - key:
2699                           name: PMSubscriptionAlbum
2700                           version: 0.0.1
2701                         value:
2702                           key:
2703                             name: PMSubscriptionAlbum
2704                             version: 0.0.1
2705                           scope: policy
2706                           isWritable: true
2707                           itemSchema:
2708                             name: PMSubscriptionType
2709                             version: 0.0.1
2710                 schemas:
2711                   key:
2712                     name: PMControlPolicy_Schemas
2713                     version: 0.0.1
2714                   schemas:
2715                     entry:
2716                       - key:
2717                           name: CDSActionIdentifiersType
2718                           version: 0.0.1
2719                         value:
2720                           key:
2721                             name: CDSActionIdentifiersType
2722                             version: 0.0.1
2723                           schemaFlavour: Avro
2724                           schemaDefinition: |-
2725                             {
2726                                 "type": "record",
2727                                 "name": "ActionIdentifiers_Type",
2728                                 "namespace": "org.onap.policy.apex.onap.helloworld",
2729                                 "fields": [
2730                                     {
2731                                         "name": "actionName",
2732                                         "type": "string"
2733                                     },
2734                                     {
2735                                         "name": "blueprintName",
2736                                         "type": "string"
2737                                     },
2738                                     {
2739                                         "name": "blueprintVersion",
2740                                         "type": "string"
2741                                     },
2742                                     {
2743                                         "name": "mode",
2744                                         "type": "string"
2745                                     }
2746                                 ]
2747                             }
2748                       - key:
2749                           name: CDSCreateResponsePayloadType
2750                           version: 0.0.1
2751                         value:
2752                           key:
2753                             name: CDSCreateResponsePayloadType
2754                             version: 0.0.1
2755                           schemaFlavour: Avro
2756                           schemaDefinition: |-
2757                             {
2758                               "name": "CreateResponsePayloadEntry",
2759                               "type": "record",
2760                               "namespace": "com.acme.avro",
2761                               "fields": [
2762                                 {
2763                                   "name": "create_DasH_subscription_DasH_response",
2764                                   "type": {
2765                                     "name": "create_DasH_subscription_DasH_response",
2766                                     "type": "record",
2767                                     "fields": [
2768                                       {
2769                                         "name": "odl_DasH_response",
2770                                         "type": {
2771                                           "name": "odl_DasH_response",
2772                                           "type": "record",
2773                                           "fields": [
2774                                               {
2775                                                 "name": "status",
2776                                                 "type": "string"
2777                                               }
2778                                           ]
2779                                         }
2780                                       }
2781                                     ]
2782                                   }
2783                                 }
2784                               ]
2785                             }
2786                       - key:
2787                           name: CDSCreateSubscriptionPayloadType
2788                           version: 0.0.1
2789                         value:
2790                           key:
2791                             name: CDSCreateSubscriptionPayloadType
2792                             version: 0.0.1
2793                           schemaFlavour: Avro
2794                           schemaDefinition: |-
2795                             {
2796                                "type":"map",
2797                                "values":{
2798                                   "type":"record",
2799                                   "name":"CDSRequestPayloadEntry",
2800                                   "fields":[
2801                                      {
2802                                         "name":"create_DasH_subscription_DasH_properties",
2803                                         "type":{
2804                                            "name":"create_DasH_subscription_DasH_properties_record",
2805                                            "type":"record",
2806                                            "fields":[
2807                                               {
2808                                                  "name":"nfName",
2809                                                  "type":"string"
2810                                               },
2811                                               {
2812                                                  "name":"ipAddress",
2813                                                  "type":"string"
2814                                               },
2815                                               {
2816                                                  "name":"subscriptionName",
2817                                                  "type":"string"
2818                                               },
2819                                               {
2820                                                  "name":"fileBasedGP",
2821                                                  "type":"string"
2822                                               },
2823                                               {
2824                                                  "name":"fileLocation",
2825                                                  "type":"string"
2826                                               },
2827                                               {
2828                                                  "name":"measurementGroup",
2829                                                  "type":{
2830                                                     "name":"Measurement_Group_Type",
2831                                                     "type":"record",
2832                                                     "fields":[
2833                                                        {
2834                                                           "name":"measurementGroupName",
2835                                                           "type":"string"
2836                                                        },
2837                                                        {
2838                                                           "name":"measurementTypes",
2839                                                           "type":{
2840                                                              "type":"array",
2841                                                              "items":{
2842                                                                 "name":"Measurement_Types_Type",
2843                                                                 "type":"record",
2844                                                                 "fields":[
2845                                                                    {
2846                                                                       "name":"measurementType",
2847                                                                       "type":"string"
2848                                                                    }
2849                                                                 ]
2850                                                              }
2851                                                           }
2852                                                        },
2853                                                        {
2854                                                           "name":"managedObjectDNsBasic",
2855                                                           "type":{
2856                                                              "type":"array",
2857                                                              "items":{
2858                                                                 "name":"Managed_Object_Dns_Basic_Type",
2859                                                                 "type":"record",
2860                                                                 "fields":[
2861                                                                    {
2862                                                                       "name":"DN",
2863                                                                       "type":"string"
2864                                                                    }
2865                                                                 ]
2866                                                              }
2867                                                           }
2868                                                        }
2869                                                     ]
2870                                                  }
2871                                               }
2872                                            ]
2873                                         }
2874                                      }
2875                                   ]
2876                                }
2877                             }
2878                       - key:
2879                           name: CDSDeleteResponsePayloadType
2880                           version: 0.0.1
2881                         value:
2882                           key:
2883                             name: CDSDeleteResponsePayloadType
2884                             version: 0.0.1
2885                           schemaFlavour: Avro
2886                           schemaDefinition: |-
2887                             {
2888                               "name": "DeleteResponsePayloadEntry",
2889                               "type": "record",
2890                               "namespace": "com.acme.avro",
2891                               "fields": [
2892                                 {
2893                                   "name": "delete_DasH_subscription_DasH_response",
2894                                   "type": {
2895                                     "name": "delete_DasH_subscription_DasH_response",
2896                                     "type": "record",
2897                                     "fields": [
2898                                       {
2899                                         "name": "odl_DasH_response",
2900                                         "type": {
2901                                           "name": "odl_DasH_response",
2902                                           "type": "record",
2903                                           "fields": [
2904                                               {
2905                                                 "name": "status",
2906                                                 "type": "string"
2907                                               }
2908                                           ]
2909                                         }
2910                                       }
2911                                     ]
2912                                   }
2913                                 }
2914                               ]
2915                             }
2916                       - key:
2917                           name: CDSDeleteSubscriptionPayloadType
2918                           version: 0.0.1
2919                         value:
2920                           key:
2921                             name: CDSDeleteSubscriptionPayloadType
2922                             version: 0.0.1
2923                           schemaFlavour: Avro
2924                           schemaDefinition: |-
2925                             {
2926                                "type":"map",
2927                                "values":{
2928                                   "type":"record",
2929                                   "name":"CDSRequestPayloadEntry",
2930                                   "fields":[
2931                                      {
2932                                         "name":"delete_DasH_subscription_DasH_properties",
2933                                         "type":{
2934                                            "name":"delete_DasH_subscription_DasH_properties_record",
2935                                            "type":"record",
2936                                            "fields":[
2937                                               {
2938                                                  "name":"nfName",
2939                                                  "type":"string"
2940                                               },
2941                                               {
2942                                                  "name":"ipAddress",
2943                                                  "type":"string"
2944                                               },
2945                                               {
2946                                                  "name":"subscriptionName",
2947                                                  "type":"string"
2948                                               },
2949                                               {
2950                                                  "name":"measurementGroupName",
2951                                                  "type":"string"
2952                                               }
2953                                            ]
2954                                         }
2955                                      }
2956                                   ]
2957                                }
2958                             }
2959                       - key:
2960                           name: CDSRequestCommonHeaderType
2961                           version: 0.0.1
2962                         value:
2963                           key:
2964                             name: CDSRequestCommonHeaderType
2965                             version: 0.0.1
2966                           schemaFlavour: Avro
2967                           schemaDefinition: |-
2968                             {
2969                                 "type": "record",
2970                                 "name": "RequestCommonHeader_Type",
2971                                 "namespace": "org.onap.policy.apex.onap.helloworld",
2972                                 "fields": [
2973                                     {
2974                                         "name": "originatorId",
2975                                         "type": "string"
2976                                     },
2977                                     {
2978                                         "name": "requestId",
2979                                         "type": "string"
2980                                     },
2981                                     {
2982                                         "name": "subRequestId",
2983                                         "type": "string"
2984                                     }
2985                                 ]
2986                             }
2987                       - key:
2988                           name: CDSResponseCommonHeaderType
2989                           version: 0.0.1
2990                         value:
2991                           key:
2992                             name: CDSResponseCommonHeaderType
2993                             version: 0.0.1
2994                           schemaFlavour: Avro
2995                           schemaDefinition: |-
2996                             {
2997                                 "type": "record",
2998                                 "name": "ResponseCommonHeader_Type",
2999                                 "namespace": "org.onap.policy.apex.onap.helloworld",
3000                                 "fields": [
3001                                     {
3002                                         "name": "originatorId",
3003                                         "type": "string"
3004                                     },
3005                                     {
3006                                         "name": "requestId",
3007                                         "type": "string"
3008                                     },
3009                                     {
3010                                         "name": "subRequestId",
3011                                         "type": "string"
3012                                     },
3013                                     {
3014                                         "name": "timestamp",
3015                                         "type": "string"
3016                                     },
3017                                     {
3018                                         "name": "flags",
3019                                         "type": ["null", "string"]
3020                                     }
3021                                 ]
3022                             }
3023                       - key:
3024                           name: CDSResponseStatusType
3025                           version: 0.0.1
3026                         value:
3027                           key:
3028                             name: CDSResponseStatusType
3029                             version: 0.0.1
3030                           schemaFlavour: Avro
3031                           schemaDefinition: |-
3032                             {
3033                                 "type": "record",
3034                                 "name": "ResponseStatus_Type",
3035                                 "namespace": "org.onap.policy.apex.onap.helloworld",
3036                                 "fields": [
3037                                     {
3038                                         "name": "code",
3039                                         "type": "int"
3040                                     },
3041                                     {
3042                                         "name": "eventType",
3043                                         "type": "string"
3044                                     },
3045                                     {
3046                                         "name": "timestamp",
3047                                         "type": "string"
3048                                     },
3049                                     {
3050                                         "name": "message",
3051                                         "type": "string"
3052                                     }
3053                                 ]
3054                             }
3055                       - key:
3056                           name: PMSubscriptionType
3057                           version: 0.0.1
3058                         value:
3059                           key:
3060                             name: PMSubscriptionType
3061                             version: 0.0.1
3062                           schemaFlavour: Avro
3063                           schemaDefinition: |-
3064                             {
3065                                 "name": "PMSubscription",
3066                                 "type": "record",
3067                                 "namespace": "org.onap.policy.apex.onap.pmcontrol",
3068                                 "fields": [
3069                                     {
3070                                         "name": "nfName",
3071                                         "type": "string"
3072                                     },
3073                                     {
3074                                         "name": "ipAddress",
3075                                         "type": "string"
3076                                     },
3077                                     {
3078                                         "name": "changeType",
3079                                         "type": "string"
3080                                     },
3081                                     {
3082                                         "name": "controlLoopName",
3083                                         "type": "string"
3084                                     },
3085                                     {
3086                                         "name": "operationalPolicyName",
3087                                         "type": "string"
3088                                     },
3089                                     {
3090                                         "name": "blueprintName",
3091                                         "type": "string"
3092                                     },
3093                                     {
3094                                         "name": "blueprintVersion",
3095                                         "type": "string"
3096                                     },
3097                                     {
3098                                         "name": "subscriptionName",
3099                                         "type": "string"
3100                                     },
3101                                     {
3102                                         "name": "measurementGroupName",
3103                                         "type": "string"
3104                                     },
3105                                     {
3106                                         "name": "subscription",
3107                                         "type": {
3108                                             "name": "subscription",
3109                                             "type": "record",
3110                                             "fields": [
3111                                                 {
3112                                                     "name": "subscriptionName",
3113                                                     "type": "string"
3114                                                 },
3115                                                 {
3116                                                     "name": "fileBasedGP",
3117                                                     "type": "int"
3118                                                 },
3119                                                 {
3120                                                     "name": "fileLocation",
3121                                                     "type": "string"
3122                                                 },
3123                                                 {
3124                                                     "name": "measurementGroup",
3125                                                     "type": {
3126                                                         "name": "Measurement_Group_Type",
3127                                                         "type": "record",
3128                                                         "fields": [
3129                                                             {
3130                                                                 "name": "measurementGroupName",
3131                                                                 "type": "string"
3132                                                             },
3133                                                             {
3134                                                                 "name": "measurementTypes",
3135                                                                 "type": {
3136                                                                     "type": "array",
3137                                                                     "items": {
3138                                                                         "name": "Measurement_Types_Type",
3139                                                                         "type": "record",
3140                                                                         "fields": [
3141                                                                             {
3142                                                                                 "name": "measurementType",
3143                                                                                 "type": "string"
3144                                                                             }
3145                                                                         ]
3146                                                                     }
3147                                                                 }
3148                                                             },
3149                                                             {
3150                                                                 "name": "managedObjectDNsBasic",
3151                                                                 "type": {
3152                                                                     "type": "array",
3153                                                                     "items": {
3154                                                                         "name": "Managed_Object_Dns_Basic_Type",
3155                                                                         "type": "record",
3156                                                                         "fields": [
3157                                                                             {
3158                                                                                 "name": "DN",
3159                                                                                 "type": "string"
3160                                                                             }
3161                                                                         ]
3162                                                                     }
3163                                                                 }
3164                                                             }
3165                                                         ]
3166                                                     }
3167                                                 }
3168                                             ]
3169                                         }
3170                                     }
3171                                 ]
3172                             }
3173                       - key:
3174                           name: SimpleIntType
3175                           version: 0.0.1
3176                         value:
3177                           key:
3178                             name: SimpleIntType
3179                             version: 0.0.1
3180                           schemaFlavour: Java
3181                           schemaDefinition: java.lang.Integer
3182                       - key:
3183                           name: SimpleStringType
3184                           version: 0.0.1
3185                         value:
3186                           key:
3187                             name: SimpleStringType
3188                             version: 0.0.1
3189                           schemaFlavour: Java
3190                           schemaDefinition: java.lang.String
3191                       - key:
3192                           name: SubscriptionStatusType
3193                           version: 0.0.1
3194                         value:
3195                           key:
3196                             name: SubscriptionStatusType
3197                             version: 0.0.1
3198                           schemaFlavour: Avro
3199                           schemaDefinition: |-
3200                             {
3201                                 "type": "record",
3202                                 "name": "ActivateSubscriptionStatus_Type",
3203                                 "namespace": "org.onap.policy.apex.onap.helloworld",
3204                                 "fields": [
3205                                     {
3206                                         "name": "subscriptionName",
3207                                         "type": "string"
3208                                     },
3209                                     {
3210                                         "name": "measurementGroupName",
3211                                         "type": "string"
3212                                     },
3213                                     {
3214                                         "name": "nfName",
3215                                         "type": "string"
3216                                     },
3217                                     {
3218                                         "name": "changeType",
3219                                         "type": "string"
3220                                     },
3221                                     {
3222                                         "name": "message",
3223                                         "type": "string"
3224                                     }
3225                                 ]
3226                             }
3227                       - key:
3228                           name: SubscriptionType
3229                           version: 0.0.1
3230                         value:
3231                           key:
3232                             name: SubscriptionType
3233                             version: 0.0.1
3234                           schemaFlavour: Avro
3235                           schemaDefinition: |-
3236                             {
3237                                 "name": "subscription",
3238                                 "type": "record",
3239                                 "default": "null",
3240                                 "fields": [
3241                                     {
3242                                         "name": "subscriptionName",
3243                                         "type": "string"
3244                                     },
3245                                     {
3246                                         "name": "fileBasedGP",
3247                                         "type": "int"
3248                                     },
3249                                     {
3250                                         "name": "fileLocation",
3251                                         "type": "string"
3252                                     },
3253                                     {
3254                                         "name": "measurementGroup",
3255                                         "type": {
3256                                             "name": "Measurement_Group_Type",
3257                                             "type": "record",
3258                                             "fields": [
3259                                                 {
3260                                                     "name": "measurementGroupName",
3261                                                     "type": "string"
3262                                                 },
3263                                                 {
3264                                                     "name": "measurementTypes",
3265                                                     "type": {
3266                                                         "type": "array",
3267                                                         "items": {
3268                                                             "name": "Measurement_Types_Type",
3269                                                             "type": "record",
3270                                                             "fields": [
3271                                                                 {
3272                                                                     "name": "measurementType",
3273                                                                     "type": "string"
3274                                                                 }
3275                                                             ]
3276                                                         }
3277                                                     }
3278                                                 },
3279                                                 {
3280                                                     "name": "managedObjectDNsBasic",
3281                                                     "type": {
3282                                                         "type": "array",
3283                                                         "items": {
3284                                                             "name": "Managed_Object_Dns_Basic_Type",
3285                                                             "type": "record",
3286                                                             "fields": [
3287                                                                 {
3288                                                                     "name": "DN",
3289                                                                     "type": "string"
3290                                                                 }
3291                                                             ]
3292                                                         }
3293                                                     }
3294                                                 }
3295                                             ]
3296                                         }
3297                                     }
3298                                 ]
3299                             }
3300                       - key:
3301                           name: UUIDType
3302                           version: 0.0.1
3303                         value:
3304                           key:
3305                             name: UUIDType
3306                             version: 0.0.1
3307                           schemaFlavour: Java
3308                           schemaDefinition: java.util.UUID
3309           eventInputParameters:
3310             DCAEConsumer:
3311               carrierTechnologyParameters:
3312                 carrierTechnology: RESTCLIENT
3313                 parameterClassName: org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters
3314                 parameters:
3315                   consumerPollTime: '50'
3316                   url: https://message-router:3905/events/unauthenticated.DCAE_CL_OUTPUT/cg1/sg1
3317               eventProtocolParameters:
3318                 eventProtocol: JSON
3319                 parameters:
3320                   nameAlias: operationalPolicyName
3321               eventName: pmsh-operational-policy
3322               eventNameFilter: pmsh-operational-policy
3323             CDSRequestConsumer:
3324               carrierTechnologyParameters:
3325                 carrierTechnology: RESTREQUESTOR
3326                 parameterClassName: org.onap.policy.apex.plugins.event.carrier.restrequestor.RestRequestorCarrierTechnologyParameters
3327                 parameters:
3328                   url: http://cds-blueprints-processor-http:8080/api/v1/execution-service/process
3329                   httpMethod: POST
3330                   restRequestTimeout: 2000
3331                   httpHeaders:
3332                     - - Authorization
3333                       - Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==
3334               eventProtocolParameters:
3335                 eventProtocol: JSON
3336               eventName: CDSCreateResponseEvent
3337               eventNameFilter: CDSCreateResponseEvent
3338               requestorMode: true
3339               requestorPeer: CDSRequestProducer
3340               requestorTimeout: 500
3341             CDSDeleteRequestConsumer:
3342               carrierTechnologyParameters:
3343                 carrierTechnology: RESTREQUESTOR
3344                 parameterClassName: org.onap.policy.apex.plugins.event.carrier.restrequestor.RestRequestorCarrierTechnologyParameters
3345                 parameters:
3346                   url: http://cds-blueprints-processor-http:8080/api/v1/execution-service/process
3347                   httpMethod: POST
3348                   restRequestTimeout: 2000
3349                   httpHeaders:
3350                     - - Authorization
3351                       - Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==
3352               eventProtocolParameters:
3353                 eventProtocol: JSON
3354               eventName: CDSDeleteResponseEvent
3355               eventNameFilter: CDSDeleteResponseEvent
3356               requestorMode: true
3357               requestorPeer: CDSDeleteRequestProducer
3358               requestorTimeout: 500
3359           eventOutputParameters:
3360             logOutputter:
3361               carrierTechnologyParameters:
3362                 carrierTechnology: FILE
3363                 parameters:
3364                   standardIo: true
3365               eventProtocolParameters:
3366                 eventProtocol: JSON
3367             StdOutOutputter:
3368               carrierTechnologyParameters:
3369                 carrierTechnology: FILE
3370                 parameters:
3371                   standardIo: true
3372               eventProtocolParameters:
3373                 eventProtocol: JSON
3374             CDSRequestProducer:
3375               carrierTechnologyParameters:
3376                 carrierTechnology: RESTREQUESTOR
3377                 parameterClassName: org.onap.policy.apex.plugins.event.carrier.restrequestor.RestRequestorCarrierTechnologyParameters
3378               eventProtocolParameters:
3379                 eventProtocol: JSON
3380               eventNameFilter: CDSCreateSubscriptionRequestEvent
3381               requestorMode: true
3382               requestorPeer: CDSRequestConsumer
3383               requestorTimeout: 500
3384             CDSDeleteRequestProducer:
3385               carrierTechnologyParameters:
3386                 carrierTechnology: RESTREQUESTOR
3387                 parameterClassName: org.onap.policy.apex.plugins.event.carrier.restrequestor.RestRequestorCarrierTechnologyParameters
3388               eventProtocolParameters:
3389                 eventProtocol: JSON
3390               eventNameFilter: CDSDeleteSubscriptionRequestEvent
3391               requestorMode: true
3392               requestorPeer: CDSDeleteRequestConsumer
3393               requestorTimeout: 500
3394             CDSReplyProducer:
3395               carrierTechnologyParameters:
3396                 carrierTechnology: RESTCLIENT
3397                 parameterClassName: org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters
3398                 parameters:
3399                   url: https://message-router:3905/events/unauthenticated.PMSH_CL_INPUT
3400                   httpMethod: POST
3401                   restRequestTimeout: 2000
3402               eventProtocolParameters:
3403                 eventProtocol: JSON
3404               eventNameFilter: CDSResponseStatusEvent