Test # | Description | Result |
---|
1 | Deploy Policy #1. Trigger event and make sure expected output is fired. Verify PDP_UPDATE message has Policy 1 in policiesToBeDeployed list and nothing in policiesToBeUndeployed list. Verify PDP_STATUS message is replying back with Policy 1 ONLY. Verify that in the Heartbeat message only Policy 1 is returned. |
"policyExecutedCount":1,"policyExecutedSuccessCount":1,"policyExecutedFailCount":0
2021-05-07T09:13:39.012+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . . .
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},"contextParameters":{"parameterClassName":"org.onap.policy.apex.context.parameters.ContextParameters","schemaParameters":{"Avro":{"parameterClassName":"org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"}}}},"policy_type_impl":{"apexPolicyModel":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"keyInformation":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"keyInfoMap":{"entry":[{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"UUID":"b8424cdb-29fb-3566-b77a-f4f847d81cc9","description":"Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"UUID":"9922906c-ccaa-34f7-95e2-bcc36e77821b","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"UUID":"5bf28afd-787c-3138-a3e1-b33ad94a038a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"UUID":"68abaa6f-8d03-3a53-9590-007115817d5c","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"UUID":"819d06c3-33c2-3031-aa78-96281aa4270a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"UUID":"8e67d466-f990-3a39-9fd7-4490cac342dc","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"UUID":"4668db3d-6fe2-3885-8e47-f30cd0102f0a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\""}},{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"UUID":"6e5fa19b-14df-37e3-a4ae-8c537e861a82","description":"Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\""}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"UUID":"8350ac5e-c157-38b9-9614-a0f93a830e60","description":"Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"UUID":"12658406-9147-3c9d-a38c-5ad5e30b092b","description":"Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"UUID":"35590ac0-062c-39f1-8786-b4ff716e30b1","description":"Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"UUID":"dd7e1805-885a-350b-aaf9-ed541321ae3c","description":"Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"UUID":"15161037-9ac8-3223-820f-4e743562a345","description":"Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\""}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"UUID":"97dc5f58-25bb-3c20-8d53-fdb70d7ca256","description":"Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\""}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"UUID":"7986e21b-32f7-302e-9554-31f21b673493","description":"Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\""}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"UUID":"92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa","description":"Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\""}},{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"UUID":"d22c78a5-272c-391d-8083-28588280caf9","description":"Generated description for concept referred to by key \"CDSResponseTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"92162397-1a8e-3a3f-a469-d2af7700af4a","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"UUID":"bc0c69f0-52ed-38ea-b468-ae4a6fd1730d","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"UUID":"7cfcf843-337e-3f41-b755-5043cb0a08fc","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"UUID":"89cb75e9-f06c-30d3-b4ff-698d45f63869","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"994fa441-04ab-33bb-832d-1cd12ab5d074","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"UUID":"0f519117-5fea-3e4b-941f-8f778100465f","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"UUID":"15d618d8-1689-3a05-89a5-05efa9388f65","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"UUID":"acb772fe-d442-39e3-98f9-b1080caf4150","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"UUID":"c2bd6f0d-6854-317a-9be2-97c08338428c","description":"Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\""}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"UUID":"992b7819-9f69-3aa0-bb0f-6e45ea15ce05","description":"Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\""}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"UUID":"73c1c397-4fc3-357f-93b6-a8ad707fbaae","description":"Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\""}},{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"UUID":"568b7345-9de1-36d3-b6a3-9b857e6809a1","description":"Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\""}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"UUID":"6c1c6c45-26e0-3591-94bf-679d20e283f4","description":"Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\""}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"UUID":"153791fd-ae0a-36a7-88a5-309a7936415d","description":"Generated description for concept referred to by key \"SimpleIntType:0.0.1\""}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"UUID":"8a4957cf-9493-3a76-8c22-a208e23259af","description":"Generated description for concept referred to by key \"SimpleStringType:0.0.1\""}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"UUID":"597643b1-9db1-31ce-85d0-e1c63c43b30b","description":"Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\""}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"UUID":"184547bb-7d64-3cb2-a273-d7185102c5ce","description":"Generated description for concept referred to by key \"SubscriptionType:0.0.1\""}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"UUID":"6a8cc68e-dfc8-3403-9c6d-071c886b319c","description":"Generated description for concept referred to by key \"UUIDType:0.0.1\""}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"UUID":"ead590a3-ba2e-3a01-b6e9-9329f5c8fee1","description":"Generated description for concept referred to by key \"testPolicyB:0.0.1\""}}]}},"policies":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"policyMap":{"entry":[{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"policyKey":{"name":"ReceiveEventPolicy","version":"0.0.1"},"template":"Freestyle","state":{"entry":[{"key":"ReceiveSubscriptionState","value":{"stateKey":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"NULL","localName":"ReceiveSubscriptionState"},"trigger":{"name":"testPolicyB","version":"0.0.1"},"stateOutputs":{"entry":[{"key":"ReceivePMSubscriptionOutput","value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"},"outgoingEvent":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nextState":{"parentKeyName":"NULL","parentKeyVersion":"0.0.0","parentLocalName":"NULL","localName":"NULL"}}}]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskSelectionLogic":{"key":"NULL","logicFlavour":"UNDEFINED","logic":""},"stateFinalizerLogicMap":{"entry":[]},"defaultTask":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"taskReferences":{"entry":[{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceiveEventPolicy"},"outputType":"DIRECT","output":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"}}}]}}}]},"firstState":"ReceiveSubscriptionState"}}]}},"tasks":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"taskMap":{"entry":[{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\n\nvar uuidType = java.util.UUID;\n\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(albumID.toString());\n\nvar responseStatus = executor.subject.getOutFieldSchemaHelper(\"status\").createNewInstance();\n\nresponseStatus.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\nresponseStatus.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\nresponseStatus.put(\"changeType\", pmSubscriptionInfo.get(\"changeType\"))\n\nvar response = executor.inFields.get(\"payload\")\n\nif (\"failure\".equals(response.get(\"create_DasH_subscription_DasH_response\").get(\"odl_DasH_response\").get(\"status\"))) {\n responseStatus.put(\"message\", \"failed\")\n} else {\n responseStatus.put(\"message\", \"success\")\n}\n\nexecutor.outFields.put(\"status\", responseStatus)\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"create_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\", pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"create_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.logger.info(\"CDS payload - \" + executor.stringify2Json( payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"));\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Create Subscription Event to CDS\");\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"create-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Activate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"delete_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\", pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"delete_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"delete_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"))\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending delete Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"delete-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Deactivate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\nvar uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\n\nvar headers = new HashMapType();\n //headers.put(\"Authorization\" , \"Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==\");\nexecutor.logger.info(\"LogEvent11111111111\");\nvar response = new org.onap.policy.rest.RestManager().post(\n \"http://10.2.0.149:32005/events/POLICY-CL-MGT\",\n \"\",\n \"\",\n headers,\n \"application/json\",\n '{\"test\":\"test\"}'\n);\nexecutor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n\n//albumID will be used to fetch info from our album later\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;;\n\nif (executor.inFields.get(\"policyName\") != null) {\n var changeType = executor.inFields.get(\"changeType\")\n var nfName = executor.inFields.get(\"nfName\")\n var policyName = executor.inFields.get(\"policyName\")\n var closedLoopControlName = executor.inFields.get(\"closedLoopControlName\")\n var subscription = executor.inFields.get(\"subscription\")\n\n var obj = {};\n obj[\"nfName\"] = executor.inFields.get(\"nfName\")\n executor.logger.info(\"nfName\" + executor.stringify2Json(obj))\n\n var ticketInfo = new HashMapType();\n populate_creator_info(ticketInfo);\n executor.logger.info(\"ticketInfo\" + executor.stringify2Json(ticketInfo))\n\n pmSubscriptionInfo.put(\"nfName\", executor.inFields.get(\"nfName\"));\n pmSubscriptionInfo.put(\"changeType\", executor.inFields.get(\"changeType\"))\n pmSubscriptionInfo.put(\"policyName\", executor.inFields.get(\"policyName\"))\n pmSubscriptionInfo.put(\"closedLoopControlName\", executor.inFields.get(\"closedLoopControlName\"))\n pmSubscriptionInfo.put(\"subscription\", subscription)\n\n executor.getContextAlbum(\"PMSubscriptionAlbum\").put(albumID.toString(), pmSubscriptionInfo);\n\n executor.outFields.put(\"albumID\", albumID)\n} else {\n executor.message = \"Received invalid event\"\n returnValue = false;\n}\n\nfunction populate_creator_info(ticketInfo){\n populate_field(ticketInfo, \"appId\", \"NSO\");\n populate_field(ticketInfo, \"creatorId\", \"fidLab\");\n populate_field(ticketInfo, \"creatorFirstName\", \"PSO\");\n populate_field(ticketInfo, \"creatorLastName\", \"team7\");\n populate_field(ticketInfo, \"creatorGroup\", \"PSO-team7\");\n populate_field(ticketInfo, \"creatorPEIN\", \"0000000\");\n populate_field(ticketInfo, \"creatorPhoneNumber\", \"800-450-7771\");\n populate_field(ticketInfo, \"fid\", \"fidLab\");\n populate_field(ticketInfo, \"organizationCode\", \"PSO\");\n populate_field(ticketInfo, \"source\", create_caEn_value(\"SURV/ALARM FROM/PSO\"));\n populate_field(ticketInfo, \"customerName\", \"XYZ\");\n populate_field(ticketInfo, \"authorization\", \"Basic dGVzdHVzZXI=\");\n}\n\nfunction populate_field(mapname, name, value){\n if (value == null){\n mapname.put(name, \"none\");\n } else{\n mapname.put(name, value);\n }\n\n}\n\nfunction create_caEn_value(value){\n var attr = {};\n attr[\"caEn\"] = String(value);\n return attr;\n}\n\nreturnValue;"}}}]}},"events":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"eventMap":{"entry":[{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"CDS","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"DCAE","parameter":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"DCAE","target":"APEX","parameter":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]}}}]}},"albums":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"albums":{"entry":[{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"scope":"policy","isWritable":true,"itemSchema":{"name":"PMSubscriptionType","version":"0.0.1"}}}]}},"schemas":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"schemas":{"entry":[{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSActionIdentifiers_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"actionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"blueprintName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"blueprintVersion\",\n \"type\": \"string\"\n },\n {\n \"name\": \"mode\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"create_DasH_subscription_DasH_properties\",\n \"type\": {\n \"name\": \"create_DasH_subscription_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementGroups_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"measurementGroup\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementTypes_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"managedObjectDNsBasic_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n}"}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"delete_DasH_subscription_DasH_properties\",\n \"type\": {\n \"name\": \"delete_DasH_subscription_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementGroups_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"measurementGroup\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementTypes_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"managedObjectDNsBasic_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n}"}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSRequestCommonHeader_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"originatorId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"requestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subRequestId\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"originatorId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"requestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subRequestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"CDSResponsePayloadEntry\",\n \"type\": \"record\",\n \"namespace\": \"com.acme.avro\",\n \"fields\": [\n {\n \"name\": \"create_DasH_subscription_DasH_response\",\n \"type\": {\n \"name\": \"create_DasH_subscription_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"odl_DasH_response\",\n \"type\": {\n \"name\": \"odl_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"status\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }\n }\n ]\n}"}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"code\",\n \"type\": \"int\"\n },\n {\n \"name\": \"eventType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"PMSubscription\",\n \"type\": \"record\",\n \"namespace\": \"org.onap.policy.apex.onap.pmcontrol\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"changeType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"closedLoopControlName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"policyName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscription\",\n \"type\": {\n \"name\": \"subscription\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"int\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Groups_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"Measurement_Group_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Types_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Managed_Object_Dns_Basic_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n}"}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.Integer"}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.String"}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"ActivateSubscriptionStatus_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"changeType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"subscription\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"int\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Groups_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"Measurement_Group_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Types_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Managed_Object_Dns_Basic_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n}"}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.util.UUID"}}]}}}}},"eventOutputParameters":{"logOutputter01":{"carrierTechnologyParameters":{"carrierTechnology":"FILE","parameters":{"fileName":"outputevents.log"}},"eventProtocolParameters":{"eventProtocol":"JSON"}}},"eventInputParameters":{"DCAEConsumer01":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyB"}},"eventName":"testPolicyB","eventNameFilter":"testPolicyB"}}},"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test01","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]
[2021-05-07T09:13:39.172+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T09:13:39.171471Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":50,"policyDeploySuccessCount":37,"policyDeployFailCount":13,"policyExecutedCount":3,"policyExecutedSuccessCount":3,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819145,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150}]},"response":{"responseTo":"e51d066c-745c-4a53-b336-257a24d093fa","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"53e9c6b1-7b6a-4c56-b644-21c7f08877eb","timestampMs":1620378819171,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T09:36:53.449+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T09:36:53.448912Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":52,"policyDeploySuccessCount":39,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378914283,"eventCount":1,"lastExecutionTime":12294,"averageExecutionTime":12294.0,"upTime":95138,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150}]},"messageName":"PDP_STATUS","requestId":"bf864ee9-9b0d-40eb-a129-c7690dd1e0f1","timestampMs":1620380213448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
2 | Deploy Policy #2. Test it is running. Verify PDP_UPDATE message has Policy 2 in policiesToBeDeployed list and nothing in policiesToBeUndeployed list. Verify PDP_STATUS message is replying back with Policy 2 included. Verify that in the Heartbeat message Policy 1 AND Policy 2 is returned. |
2021-05-07T09:51:56.731+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps.", . . . .
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},"contextParameters":{"parameterClassName":"org.onap.policy.apex.context.parameters.ContextParameters","schemaParameters":{"Avro":{"parameterClassName":"org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"}}}},"policy_type_impl":{"apexPolicyModel":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"keyInformation":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"keyInfoMap":{"entry":[{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"UUID":"b8424cdb-29fb-3566-b77a-f4f847d81cc9","description":"Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"UUID":"9922906c-ccaa-34f7-95e2-bcc36e77821b","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"UUID":"5bf28afd-787c-3138-a3e1-b33ad94a038a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"UUID":"68abaa6f-8d03-3a53-9590-007115817d5c","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"UUID":"819d06c3-33c2-3031-aa78-96281aa4270a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"UUID":"8e67d466-f990-3a39-9fd7-4490cac342dc","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"UUID":"4668db3d-6fe2-3885-8e47-f30cd0102f0a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\""}},{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"UUID":"6e5fa19b-14df-37e3-a4ae-8c537e861a82","description":"Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\""}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"UUID":"8350ac5e-c157-38b9-9614-a0f93a830e60","description":"Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"UUID":"12658406-9147-3c9d-a38c-5ad5e30b092b","description":"Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"UUID":"35590ac0-062c-39f1-8786-b4ff716e30b1","description":"Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"UUID":"dd7e1805-885a-350b-aaf9-ed541321ae3c","description":"Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"UUID":"15161037-9ac8-3223-820f-4e743562a345","description":"Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\""}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"UUID":"97dc5f58-25bb-3c20-8d53-fdb70d7ca256","description":"Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\""}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"UUID":"7986e21b-32f7-302e-9554-31f21b673493","description":"Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\""}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"UUID":"92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa","description":"Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\""}},{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"UUID":"d22c78a5-272c-391d-8083-28588280caf9","description":"Generated description for concept referred to by key \"CDSResponseTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"92162397-1a8e-3a3f-a469-d2af7700af4a","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"UUID":"bc0c69f0-52ed-38ea-b468-ae4a6fd1730d","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"UUID":"7cfcf843-337e-3f41-b755-5043cb0a08fc","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"UUID":"89cb75e9-f06c-30d3-b4ff-698d45f63869","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"994fa441-04ab-33bb-832d-1cd12ab5d074","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"UUID":"0f519117-5fea-3e4b-941f-8f778100465f","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"UUID":"15d618d8-1689-3a05-89a5-05efa9388f65","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"UUID":"acb772fe-d442-39e3-98f9-b1080caf4150","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"UUID":"c2bd6f0d-6854-317a-9be2-97c08338428c","description":"Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\""}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"UUID":"992b7819-9f69-3aa0-bb0f-6e45ea15ce05","description":"Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\""}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"UUID":"73c1c397-4fc3-357f-93b6-a8ad707fbaae","description":"Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\""}},{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"UUID":"568b7345-9de1-36d3-b6a3-9b857e6809a1","description":"Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\""}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"UUID":"6c1c6c45-26e0-3591-94bf-679d20e283f4","description":"Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\""}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"UUID":"153791fd-ae0a-36a7-88a5-309a7936415d","description":"Generated description for concept referred to by key \"SimpleIntType:0.0.1\""}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"UUID":"8a4957cf-9493-3a76-8c22-a208e23259af","description":"Generated description for concept referred to by key \"SimpleStringType:0.0.1\""}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"UUID":"597643b1-9db1-31ce-85d0-e1c63c43b30b","description":"Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\""}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"UUID":"184547bb-7d64-3cb2-a273-d7185102c5ce","description":"Generated description for concept referred to by key \"SubscriptionType:0.0.1\""}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"UUID":"6a8cc68e-dfc8-3403-9c6d-071c886b319c","description":"Generated description for concept referred to by key \"UUIDType:0.0.1\""}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"UUID":"ead590a3-ba2e-3a01-b6e9-9329f5c8fee1","description":"Generated description for concept referred to by key \"testPolicyB:0.0.1\""}}]}},"policies":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"policyMap":{"entry":[{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"policyKey":{"name":"ReceiveEventPolicy","version":"0.0.1"},"template":"Freestyle","state":{"entry":[{"key":"ReceiveSubscriptionState","value":{"stateKey":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"NULL","localName":"ReceiveSubscriptionState"},"trigger":{"name":"testPolicyB","version":"0.0.1"},"stateOutputs":{"entry":[{"key":"ReceivePMSubscriptionOutput","value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"},"outgoingEvent":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nextState":{"parentKeyName":"NULL","parentKeyVersion":"0.0.0","parentLocalName":"NULL","localName":"NULL"}}}]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskSelectionLogic":{"key":"NULL","logicFlavour":"UNDEFINED","logic":""},"stateFinalizerLogicMap":{"entry":[]},"defaultTask":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"taskReferences":{"entry":[{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceiveEventPolicy"},"outputType":"DIRECT","output":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"}}}]}}}]},"firstState":"ReceiveSubscriptionState"}}]}},"tasks":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"taskMap":{"entry":[{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\n\nvar uuidType = java.util.UUID;\n\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(albumID.toString());\n\nvar responseStatus = executor.subject.getOutFieldSchemaHelper(\"status\").createNewInstance();\n\nresponseStatus.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\nresponseStatus.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\nresponseStatus.put(\"changeType\", pmSubscriptionInfo.get(\"changeType\"))\n\nvar response = executor.inFields.get(\"payload\")\n\nif (\"failure\".equals(response.get(\"create_DasH_subscription_DasH_response\").get(\"odl_DasH_response\").get(\"status\"))) {\n responseStatus.put(\"message\", \"failed\")\n} else {\n responseStatus.put(\"message\", \"success\")\n}\n\nexecutor.outFields.put(\"status\", responseStatus)\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"create_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\", pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"create_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.logger.info(\"CDS payload - \" + executor.stringify2Json( payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"));\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Create Subscription Event to CDS\");\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"create-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Activate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"delete_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\", pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"delete_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"delete_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"))\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending delete Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"delete-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Deactivate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\nvar uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\n\nvar headers = new HashMapType();\n //headers.put(\"Authorization\" , \"Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==\");\nexecutor.logger.info(\"LogEvent11111111111\");\nvar response = new org.onap.policy.rest.RestManager().post(\n \"http://10.2.0.149:32005/events/POLICY-CL-MGT\",\n \"\",\n \"\",\n headers,\n \"application/json\",\n '{\"test\":\"test\"}'\n);\nexecutor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n\n//albumID will be used to fetch info from our album later\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;;\n\nif (executor.inFields.get(\"policyName\") != null) {\n var changeType = executor.inFields.get(\"changeType\")\n var nfName = executor.inFields.get(\"nfName\")\n var policyName = executor.inFields.get(\"policyName\")\n var closedLoopControlName = executor.inFields.get(\"closedLoopControlName\")\n var subscription = executor.inFields.get(\"subscription\")\n\n var obj = {};\n obj[\"nfName\"] = executor.inFields.get(\"nfName\")\n executor.logger.info(\"nfName\" + executor.stringify2Json(obj))\n\n var ticketInfo = new HashMapType();\n populate_creator_info(ticketInfo);\n executor.logger.info(\"ticketInfo\" + executor.stringify2Json(ticketInfo))\n\n pmSubscriptionInfo.put(\"nfName\", executor.inFields.get(\"nfName\"));\n pmSubscriptionInfo.put(\"changeType\", executor.inFields.get(\"changeType\"))\n pmSubscriptionInfo.put(\"policyName\", executor.inFields.get(\"policyName\"))\n pmSubscriptionInfo.put(\"closedLoopControlName\", executor.inFields.get(\"closedLoopControlName\"))\n pmSubscriptionInfo.put(\"subscription\", subscription)\n\n executor.getContextAlbum(\"PMSubscriptionAlbum\").put(albumID.toString(), pmSubscriptionInfo);\n\n executor.outFields.put(\"albumID\", albumID)\n} else {\n executor.message = \"Received invalid event\"\n returnValue = false;\n}\n\nfunction populate_creator_info(ticketInfo){\n populate_field(ticketInfo, \"appId\", \"NSO\");\n populate_field(ticketInfo, \"creatorId\", \"fidLab\");\n populate_field(ticketInfo, \"creatorFirstName\", \"PSO\");\n populate_field(ticketInfo, \"creatorLastName\", \"team7\");\n populate_field(ticketInfo, \"creatorGroup\", \"PSO-team7\");\n populate_field(ticketInfo, \"creatorPEIN\", \"0000000\");\n populate_field(ticketInfo, \"creatorPhoneNumber\", \"800-450-7771\");\n populate_field(ticketInfo, \"fid\", \"fidLab\");\n populate_field(ticketInfo, \"organizationCode\", \"PSO\");\n populate_field(ticketInfo, \"source\", create_caEn_value(\"SURV/ALARM FROM/PSO\"));\n populate_field(ticketInfo, \"customerName\", \"XYZ\");\n populate_field(ticketInfo, \"authorization\", \"Basic dGVzdHVzZXI=\");\n}\n\nfunction populate_field(mapname, name, value){\n if (value == null){\n mapname.put(name, \"none\");\n } else{\n mapname.put(name, value);\n }\n\n}\n\nfunction create_caEn_value(value){\n var attr = {};\n attr[\"caEn\"] = String(value);\n return attr;\n}\n\nreturnValue;"}}}]}},"events":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"eventMap":{"entry":[{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"CDS","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"DCAE","parameter":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"DCAE","target":"APEX","parameter":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]}}}]}},"albums":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"albums":{"entry":[{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"scope":"policy","isWritable":true,"itemSchema":{"name":"PMSubscriptionType","version":"0.0.1"}}}]}},"schemas":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"schemas":{"entry":[{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSActionIdentifiers_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"actionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"blueprintName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"blueprintVersion\",\n \"type\": \"string\"\n },\n {\n \"name\": \"mode\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"create_DasH_subscription_DasH_properties\",\n \"type\": {\n \"name\": \"create_DasH_subscription_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementGroups_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"measurementGroup\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementTypes_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"managedObjectDNsBasic_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n}"}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"delete_DasH_subscription_DasH_properties\",\n \"type\": {\n \"name\": \"delete_DasH_subscription_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementGroups_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"measurementGroup\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementTypes_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"managedObjectDNsBasic_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n}"}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSRequestCommonHeader_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"originatorId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"requestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subRequestId\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"originatorId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"requestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subRequestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"CDSResponsePayloadEntry\",\n \"type\": \"record\",\n \"namespace\": \"com.acme.avro\",\n \"fields\": [\n {\n \"name\": \"create_DasH_subscription_DasH_response\",\n \"type\": {\n \"name\": \"create_DasH_subscription_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"odl_DasH_response\",\n \"type\": {\n \"name\": \"odl_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"status\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }\n }\n ]\n}"}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"code\",\n \"type\": \"int\"\n },\n {\n \"name\": \"eventType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"PMSubscription\",\n \"type\": \"record\",\n \"namespace\": \"org.onap.policy.apex.onap.pmcontrol\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"changeType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"closedLoopControlName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"policyName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscription\",\n \"type\": {\n \"name\": \"subscription\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"int\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Groups_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"Measurement_Group_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Types_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Managed_Object_Dns_Basic_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n}"}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.Integer"}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.String"}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"ActivateSubscriptionStatus_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"changeType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"subscription\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"int\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Groups_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"Measurement_Group_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Types_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Managed_Object_Dns_Basic_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n}"}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.util.UUID"}}]}}}}},"eventOutputParameters":{"logOutputter02":{"carrierTechnologyParameters":{"carrierTechnology":"FILE","parameters":{"fileName":"outputevents.log"}},"eventProtocolParameters":{"eventProtocol":"JSON"}}},"eventInputParameters":{"DCAEConsumer02":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyC"}},"eventName":"testPolicyC","eventNameFilter":"testPolicyC"}}},"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test02","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]
[2021-05-07T09:51:56.817+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T09:51:56.816871Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":53,"policyDeploySuccessCount":40,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378914283,"eventCount":1,"lastExecutionTime":12294,"averageExecutionTime":12294.0,"upTime":95138,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"response":{"responseTo":"26b5a061-0d2b-4d51-b6d9-82fa070bfa2b","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"31a82b3e-8b00-4ed4-b416-a60030252f38","timestampMs":1620381116816,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T10:02:54.148+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:02:53.449056Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":53,"policyDeploySuccessCount":40,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378914283,"eventCount":1,"lastExecutionTime":12294,"averageExecutionTime":12294.0,"upTime":95138,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"messageName":"PDP_STATUS","requestId":"2717f480-9c10-4574-a85f-ed6043b6c795","timestampMs":1620381773449,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
3 | Undeploy Policy #1. Verify Policy #2 is still running. Verify policiesToBeUndeployed list contains Policy 1. Verify PDP_STATUS message does not contain Policy 1. Verify Heartbeat only has Policy 2. |
[2021-05-07T10:24:07.540+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . .
.
.
"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"09d262c5-34cb-4a22-8853-d83f3264ccec","timestampMs":1620383045958,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T10:24:07.825+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:24:07.825165Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"response":{"responseTo":"09d262c5-34cb-4a22-8853-d83f3264ccec","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"46c9b20a-71c1-4c50-81ad-a493b895d071","timestampMs":1620383047825,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T10:26:54.113+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:26:53.449146Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"messageName":"PDP_STATUS","requestId":"86480e16-083b-46d9-b39e-3f0392e6c255","timestampMs":1620383213449,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
4 | Undeploy Policy #2. Verify no policies are running. Verify Policy 2 is in policiesToBeUndeployed list. Very Policy 2 is not in PDP_STATUS list of policies. Verify no policies are running. Very Policy 2 is not in Heartbeat message. |
[2021-05-07T10:29:38.862+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps.","policies":[],"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"fbce7644-69d2-4b00-82cc-159d2e6171a1","timestampMs":1620383378137,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T10:29:38.862+00:00|WARN|Registry|DMAAP-source-POLICY-PDP-PAP] replacing previously registered: object:apex/tosca/policy/list
[2021-05-07T10:29:39.164+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:29:39.164124Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[]},"response":{"responseTo":"fbce7644-69d2-4b00-82cc-159d2e6171a1","responseStatus":"SUCCESS","responseMessage":"Pdp update successful. No policies are running."},"messageName":"PDP_STATUS","requestId":"01b98607-524e-4f77-98b6-ac4342e53cf0","timestampMs":1620383379164,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T10:30:53.448+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:30:53.448595Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[]},"messageName":"PDP_STATUS","requestId":"a020a375-5671-44e9-9876-00c22a876553","timestampMs":1620383453448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
5 | Deploy Policy #1, #2, #3. Make sure all are running. |
[2021-05-07T11:52:57.432+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps. . .
.
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},
.
.
.
"metadata":{"policy-id":"onap.policies.native.apex.Grpc.test03","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]
2021-05-07T11:52:57.684+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T11:52:57.684007Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":55,"policyDeploySuccessCount":42,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377600,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377600},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377604,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377604},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"d534d254-cb6d-4cfb-99cb-94e167fb5504","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"76b5edee-db9e-400e-b01f-7d00413fee9b","timestampMs":1620388377683,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T11:54:53.453+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T11:54:53.448764Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":55,"policyDeploySuccessCount":42,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377600,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377600},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377604,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377604},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"messageName":"PDP_STATUS","requestId":"642f3af4-7752-410e-a6c4-39e39cbbcaae","timestampMs":1620388493448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
6 | Undeploy Policy #2. Make sure Policy #1 and Policy #2 are running. Remove Policies #1 & #3. Make sure none are running. Verify ALL policies in policiesToBeDeployed. Verify ALL policies in PDP_STATUS message. Verify ALL policies in heartbeat. |
[2021-05-07T12:14:13.097+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . .
.
.
"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"ebe313d7-a48a-4e2b-96d9-0e6fc38feef8","timestampMs":1620389652214,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:14:13.383+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:14:13.382804Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":56,"policyDeploySuccessCount":43,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"ebe313d7-a48a-4e2b-96d9-0e6fc38feef8","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"e2bb4044-c33a-4810-baf9-7d720400aff1","timestampMs":1620389653382,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:16:54.117+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:16:53.448840Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":56,"policyDeploySuccessCount":43,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"messageName":"PDP_STATUS","requestId":"7ea03028-a6db-4bfb-96d3-847af75a4652","timestampMs":1620389813448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
#7 | Deploy Policy to fail. |
[2021-05-07T12:21:13.105+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . .
.
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},"contextParameters":{"parameterClassName":"org.onap.policy.apex.context.parameters.ContextParameters","schemaParameters":{"Avro":{"parameterClassName":"org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"}}}},"policy_type_impl":{"apexPolicyModel":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"keyInformation":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"keyInfoMap":{"entry":[{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"UUID":"b8424cdb-29fb-3566-b77a-f4f847d81cc9","description":"Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"UUID":"9922906c-ccaa-34f7-95e2-bcc36e77821b","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"UUID":"5bf28afd-787c-3138-a3e1-b33ad94a038a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"UUID":"68abaa6f-8d03-3a53-9590-007115817d5c","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"UUID":"819d06c3-33c2-3031-aa78-96281aa4270a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"UUID":"8e67d466-f990-3a39-9fd7-4490cac342dc","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"UUID":"4668db3d-6fe2-3885-8e47-f30cd0102f0a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\""}},{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"UUID":"6e5fa19b-14df-37e3-a4ae-8c537e861a82","description":"Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\""}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"UUID":"8350ac5e-c157-38b9-9614-a0f93a830e60","description":"Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"UUID":"12658406-9147-3c9d-a38c-5ad5e30b092b","description":"Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"UUID":"35590ac0-062c-39f1-8786-b4ff716e30b1","description":"Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"UUID":"dd7e1805-885a-350b-aaf9-ed541321ae3c","description":"Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"UUID":"15161037-9ac8-3223-820f-4e743562a345","description":"Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\""}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"UUID":"97dc5f58-25bb-3c20-8d53-fdb70d7ca256","description":"Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\""}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"UUID":"7986e21b-32f7-302e-9554-31f21b673493","description":"Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\""}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"UUID":"92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa","description":"Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\""}},{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"UUID":"d22c78a5-272c-391d-8083-28588280caf9","description":"Generated description for concept referred to by key \"CDSResponseTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"92162397-1a8e-3a3f-a469-d2af7700af4a","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"UUID":"bc0c69f0-52ed-38ea-b468-ae4a6fd1730d","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"UUID":"7cfcf843-337e-3f41-b755-5043cb0a08fc","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"UUID":"89cb75e9-f06c-30d3-b4ff-698d45f63869","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"994fa441-04ab-33bb-832d-1cd12ab5d074","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"UUID":"0f519117-5fea-3e4b-941f-8f778100465f","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"UUID":"15d618d8-1689-3a05-89a5-05efa9388f65","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"UUID":"acb772fe-d442-39e3-98f9-b1080caf4150","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"UUID":"c2bd6f0d-6854-317a-9be2-97c08338428c","description":"Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\""}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"UUID":"992b7819-9f69-3aa0-bb0f-6e45ea15ce05","description":"Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\""}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"UUID":"73c1c397-4fc3-357f-93b6-a8ad707fbaae","description":"Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\""}},{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"UUID":"568b7345-9de1-36d3-b6a3-9b857e6809a1","description":"Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\""}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"UUID":"6c1c6c45-26e0-3591-94bf-679d20e283f4","description":"Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\""}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"UUID":"153791fd-ae0a-36a7-88a5-309a7936415d","description":"Generated description for concept referred to by key \"SimpleIntType:0.0.1\""}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"UUID":"8a4957cf-9493-3a76-8c22-a208e23259af","description":"Generated description for concept referred to by key \"SimpleStringType:0.0.1\""}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"UUID":"597643b1-9db1-31ce-85d0-e1c63c43b30b","description":"Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\""}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"UUID":"184547bb-7d64-3cb2-a273-d7185102c5ce","description":"Generated description for concept referred to by key \"SubscriptionType:0.0.1\""}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"UUID":"6a8cc68e-dfc8-3403-9c6d-071c886b319c","description":"Generated description for concept referred to by key \"UUIDType:0.0.1\""}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"UUID":"ead590a3-ba2e-3a01-b6e9-9329f5c8fee1","description":"Generated description for concept referred to by key \"testPolicyB:0.0.1\""}}]}},"policies":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"policyMap":{"entry":[{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"policyKey":{"name":"ReceiveEventPolicy","version":"0.0.1"},"template":"Freestyle","state":{"entry":[{"key":"ReceiveSubscriptionState","value":{"stateKey":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"NULL","localName":"ReceiveSubscriptionState"},"trigger":{"name":"testPolicyB","version":"0.0.1"},"stateOutputs":{"entry":[{"key":"ReceivePMSubscriptionOutput","value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"},"outgoingEvent":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nextState":{"parentKeyName":"NULL","parentKeyVersion":"0.0.0","parentLocalName":"NULL","localName":"NULL"}}}]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskSelectionLogic":{"key":"NULL","logicFlavour":"UNDEFINED","logic":""},"stateFinalizerLogicMap":{"entry":[]},"defaultTask":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"taskReferences":{"entry":[{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceiveEventPolicy"},"outputType":"DIRECT","output":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"}}}]}}}]},"firstState":"ReceiveSubscriptionState"}}]}},"tasks":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"taskMap":{"entry":[{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\n\nvar uuidType = java.util.UUID;\n\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(albumID.toString());\n\nvar responseStatus = executor.subject.getOutFieldSchemaHelper(\"status\").createNewInstance();\n\nresponseStatus.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\nresponseStatus.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\nresponseStatus.put(\"changeType\", pmSubscriptionInfo.get(\"changeType\"))\n\nvar response = executor.inFields.get(\"payload\")\n\nif (\"failure\".equals(response.get(\"create_DasH_subscription_DasH_response\").get(\"odl_DasH_response\").get(\"status\"))) {\n responseStatus.put(\"message\", \"failed\")\n} else {\n responseStatus.put(\"message\", \"success\")\n}\n\nexecutor.outFields.put(\"status\", responseStatus)\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"create_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\", pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"create_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.logger.info(\"CDS payload - \" + executor.stringify2Json( payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"));\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Create Subscription Event to CDS\");\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"create-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Activate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"delete_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\", pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"delete_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"delete_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"))\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending delete Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"delete-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Deactivate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\nvar uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\n\nvar headers = new HashMapType();\n //headers.put(\"Authorization\" , \"Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==\");\nexecutor.logger.info(\"LogEvent11111111111\");\nvar response = new org.onap.policy.rest.RestManager().post(\n \"http://10.2.0.149:32005/events/POLICY-CL-MGT\",\n \"\",\n \"\",\n headers,\n \"application/json\",\n '{\"test\":\"test\"}'\n);\nexecutor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n\n//albumID will be used to fetch info from our album later\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;;\n\nif (executor.inFields.get(\"policyName\") != null) {\n var changeType = executor.inFields.get(\"changeType\")\n var nfName = executor.inFields.get(\"nfName\")\n var policyName = executor.inFields.get(\"policyName\")\n var closedLoopControlName = executor.inFields.get(\"closedLoopControlName\")\n var subscription = executor.inFields.get(\"subscription\")\n\n var obj = {};\n obj[\"nfName\"] = executor.inFields.get(\"nfName\")\n executor.logger.info(\"nfName\" + executor.stringify2Json(obj))\n\n var ticketInfo = new HashMapType();\n populate_creator_info(ticketInfo);\n executor.logger.info(\"ticketInfo\" + executor.stringify2Json(ticketInfo))\n\n pmSubscriptionInfo.put(\"nfName\", executor.inFields.get(\"nfName\"));\n pmSubscriptionInfo.put(\"changeType\", executor.inFields.get(\"changeType\"))\n pmSubscriptionInfo.put(\"policyName\", executor.inFields.get(\"policyName\"))\n pmSubscriptionInfo.put(\"closedLoopControlName\", executor.inFields.get(\"closedLoopControlName\"))\n pmSubscriptionInfo.put(\"subscription\", subscription)\n\n executor.getContextAlbum(\"PMSubscriptionAlbum\").put(albumID.toString(), pmSubscriptionInfo);\n\n executor.outFields.put(\"albumID\", albumID)\n} else {\n executor.message = \"Received invalid event\"\n returnValue = false;\n}\n\nfunction populate_creator_info(ticketInfo){\n populate_field(ticketInfo, \"appId\", \"NSO\");\n populate_field(ticketInfo, \"creatorId\", \"fidLab\");\n populate_field(ticketInfo, \"creatorFirstName\", \"PSO\");\n populate_field(ticketInfo, \"creatorLastName\", \"team7\");\n populate_field(ticketInfo, \"creatorGroup\", \"PSO-team7\");\n populate_field(ticketInfo, \"creatorPEIN\", \"0000000\");\n populate_field(ticketInfo, \"creatorPhoneNumber\", \"800-450-7771\");\n populate_field(ticketInfo, \"fid\", \"fidLab\");\n populate_field(ticketInfo, \"organizationCode\", \"PSO\");\n populate_field(ticketInfo, \"source\", create_caEn_value(\"SURV/ALARM FROM/PSO\"));\n populate_field(ticketInfo, \"customerName\", \"XYZ\");\n populate_field(ticketInfo, \"authorization\", \"Basic dGVzdHVzZXI=\");\n}\n\nfunction populate_field(mapname, name, value){\n if (value == null){\n mapname.put(name, \"none\");\n } else{\n mapname.put(name, value);\n }\n\n}\n\nfunction create_caEn_value(value){\n var attr = {};\n attr[\"caEn\"] = String(value);\n return attr;\n}\n\nreturnValue;"}}}]}},"events":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"eventMap":{"entry":[{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"CDS","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"DCAE","parameter":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"DCAE","target":"APEX","parameter":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]}}}]}},"albums":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"albums":{"entry":[{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"scope":"policy","isWritable":true,"itemSchema":{"name":"PMSubscriptionType","version":"0.0.1"}}}]}},"schemas":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"schemas":{"entry":[{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSActionIdentifiers_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"actionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"blueprintName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"blueprintVersion\",\n \"type\": \"string\"\n },\n {\n \"name\": \"mode\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"create_DasH_subscription_DasH_properties\",\n \"type\": {\n \"name\": \"create_DasH_subscription_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementGroups_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"measurementGroup\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementTypes_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"managedObjectDNsBasic_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n}"}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"delete_DasH_subscription_DasH_properties\",\n \"type\": {\n \"name\": \"delete_DasH_subscription_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementGroups_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"measurementGroup\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"measurementTypes_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"managedObjectDNsBasic_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n}"}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSRequestCommonHeader_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"originatorId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"requestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subRequestId\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"originatorId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"requestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subRequestId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"CDSResponsePayloadEntry\",\n \"type\": \"record\",\n \"namespace\": \"com.acme.avro\",\n \"fields\": [\n {\n \"name\": \"create_DasH_subscription_DasH_response\",\n \"type\": {\n \"name\": \"create_DasH_subscription_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"odl_DasH_response\",\n \"type\": {\n \"name\": \"odl_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"status\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }\n }\n ]\n}"}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"code\",\n \"type\": \"int\"\n },\n {\n \"name\": \"eventType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"PMSubscription\",\n \"type\": \"record\",\n \"namespace\": \"org.onap.policy.apex.onap.pmcontrol\",\n \"fields\": [\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"changeType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"closedLoopControlName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"policyName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"subscription\",\n \"type\": {\n \"name\": \"subscription\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"int\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Groups_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"Measurement_Group_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Types_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Managed_Object_Dns_Basic_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n}"}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.Integer"}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.String"}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"type\": \"record\",\n \"name\": \"ActivateSubscriptionStatus_Type\",\n \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"nfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"changeType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n }\n ]\n}"}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n \"name\": \"subscription\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"subscriptionName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"administrativeState\",\n \"type\": \"string\"\n },\n {\n \"name\": \"fileBasedGP\",\n \"type\": \"int\"\n },\n {\n \"name\": \"fileLocation\",\n \"type\": \"string\"\n },\n {\n \"name\": \"measurementGroups\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Groups_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementGroup\",\n \"type\": {\n \"name\": \"Measurement_Group_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementTypes\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Measurement_Types_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"measurementType\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"managedObjectDNsBasic\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"Managed_Object_Dns_Basic_Type\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"DN\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n ]\n }\n }\n }\n ]\n}"}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.util.UUID"}}]}}}}},"eventOutputParameters":{"logOutputter03":{"carrierTechnologyParameters":{"carrierTechnology":"FILE","parameters":{"fileName":"outputevents.log"}},"eventProtocolParameters":{"eventProtocol":"JSON"}}},"eventInputParameters":{"DCAEConsumer03":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyD"}},"eventName":"testPolicyD","eventNameFilter":"testPolicyD"}}},"name":"onap.policies.native.apex.Grpc.test0fail","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test0fail","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]
[2021-05-07T12:21:13.120+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:21:13.120606Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":57,"policyDeploySuccessCount":43,"policyDeployFailCount":14,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"9f3cf978-cffa-481b-80a6-fbef7da0306d","responseStatus":"FAIL","responseMessage":"Apex engine service running failed. Updating the APEX engine with new policies failed."},"messageName":"PDP_STATUS","requestId":"74a90046-04c1-405e-9e81-c0497d25ebf8","timestampMs":1620390073120,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:21:15.342+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . .
.
.
.
"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test0fail","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"3f38dd7a-19f3-4347-9e69-26147467d17f","timestampMs":1620390074460,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:21:15.345+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:21:15.345674Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":57,"policyDeploySuccessCount":43,"policyDeployFailCount":14,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"3f38dd7a-19f3-4347-9e69-26147467d17f","responseStatus":"SUCCESS","responseMessage":"Pdp already updated"},"messageName":"PDP_STATUS","requestId":"62730772-226f-4b4c-b692-5014f43194fb","timestampMs":1620390075345,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:30:54.114+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:30:53.448716Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":57,"policyDeploySuccessCount":43,"policyDeployFailCount":14,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"messageName":"PDP_STATUS","requestId":"7318dc86-d3ae-41cb-b432-ec76106933d2","timestampMs":1620390653448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
#8 | Bring down apex-pdp pod with Policy 1 and Policy 3 deployed. Bring back up the pod and verify policies are deployed upon registration. Verify heartbeat sent with no policies. Verify pdp registered. Verify PDP_UPDATE message sent with policiesToBeDeployed with Policy 1 and Policy 3 in list. Verify PDP_STATUS has Policy 1 and 3 included. Verify Heartbeat has both policies included. |
[2021-05-07T12:35:48.564+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"PASSIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:35:48.527864Z","pdpGroupName":"defaultGroup","policyDeployCount":0,"policyDeploySuccessCount":0,"policyDeployFailCount":0,"policyExecutedCount":0,"policyExecutedSuccessCount":0,"policyExecutedFailCount":0},"messageName":"PDP_STATUS","requestId":"8c053560-00e0-43f7-94e6-5d048308ac30","timestampMs":1620390948525,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup"}
[2021-05-07T12:36:21.125+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpHeartbeatIntervalMs":120000,"policies":[{"type":"onap.policies.native.Apex","type_version":"1.0.0" . .
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561
.
.
.
"eventInputParameters":{"DCAEConsumer03":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyD"}},"eventName":"testPolicyD","eventNameFilter":"testPolicyD"}}},"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test03","policy-version":"1.0.0"}}],"messageName":"PDP_UPDATE","requestId":"f219221d-25ac-4474-8585-2e85db37fe15","timestampMs":1620390950442,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:36:21.160+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"PASSIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:36:21.159886Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":0,"policyDeploySuccessCount":0,"policyDeployFailCount":0,"policyExecutedCount":0,"policyExecutedSuccessCount":0,"policyExecutedFailCount":0},"response":{"responseTo":"f219221d-25ac-4474-8585-2e85db37fe15","responseStatus":"SUCCESS","responseMessage":"Pdp update successful."},"messageName":"PDP_STATUS","requestId":"e103cd65-9d3c-4a73-bd6c-40699d4b0ca3","timestampMs":1620390981159,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T12:47:48.522+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:47:48.521403Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":1,"policyDeploySuccessCount":1,"policyDeployFailCount":0,"policyExecutedCount":0,"policyExecutedSuccessCount":0,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390983946,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390983946},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390983961,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390983961},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984090,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984090},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984101,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984101}]},"messageName":"PDP_STATUS","requestId":"6516c4cd-fcd9-4fd5-b3fe-02917715d094","timestampMs":1620391668521,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|
#9 | Send event to Policy 1 when three policies are deployed. Verify event triggers policy. |
[2021-05-07T12:59:48.524+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:59:48.521765Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":2,"policyDeploySuccessCount":2,"policyDeployFailCount":0,"policyExecutedCount":1,"policyExecutedSuccessCount":1,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620392295329,"eventCount":1,"lastExecutionTime":12375,"averageExecutionTime":12375.0,"upTime":1311383,"lastEnterTime":0,"lastStart":1620390983946},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390983961,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390983961},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984090,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984090},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984101,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984101},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620392018414,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620392018414},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620392018422,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620392018422}]},"messageName":"PDP_STATUS","requestId":"7b8f3a8f-0f13-40c6-bc18-ae1481c5c582","timestampMs":1620392388521,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
|