{"type":"doc","content":[{"type":"extension","attrs":{"extensionType":"com.atlassian.confluence.macro.core","extensionKey":"toc","parameters":{"macroParams":{},"macroMetadata":{"macroId":{"value":"a3eef4a6-6b22-4ac4-9ed0-aad5506b9a8c"},"schemaVersion":{"value":"1"},"title":"Table of Contents"}}}},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"References","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"type":"inlineCard","attrs":{"url":"https://lf-onap.atlassian.net/browse/CPS-1616"}}]},{"type":"paragraph","content":[{"text":"Impl. Proposal CM Subscriptions : Delete ( Positive Scenarios )","type":"text","marks":[{"type":"link","attrs":{"href":"https://lf-onap.atlassian.net/wiki/spaces/DW/pages/16521396"}}]}]},{"type":"paragraph","content":[{"type":"inlineCard","attrs":{"url":"https://lf-onap.atlassian.net/browse/CPS-1776"}}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Assumptions","type":"text","marks":[{"type":"strong"}]}]},{"type":"table","attrs":{"layout":"full-width"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[34.19]},"content":[{"type":"paragraph","content":[{"text":"#","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[131.17]},"content":[{"type":"paragraph","content":[{"text":"Issue","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[473.17]},"content":[{"type":"paragraph","content":[{"text":"Notes","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[435.58]},"content":[{"type":"paragraph","content":[{"text":"Decisions","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[34.19]},"content":[{"type":"paragraph","content":[{"text":"1","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[131.17]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[473.17]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[435.58]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Issues & Decisions","type":"text","marks":[{"type":"strong"}]}]},{"type":"table","attrs":{"layout":"wide"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[19.51]},"content":[{"type":"paragraph","content":[{"text":"#","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[144.63]},"content":[{"type":"paragraph","content":[{"text":"Issue","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[271.48]},"content":[{"type":"paragraph","content":[{"text":"Notes","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[250.25]},"content":[{"type":"paragraph","content":[{"text":"Decisions","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[19.51]},"content":[{"type":"paragraph","content":[{"text":"1","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[144.63]},"content":[{"type":"paragraph","content":[{"text":"Schema of the outcome response message (Schema 5)","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[271.48]},"content":[{"type":"paragraph","content":[{"text":"Open Questions:","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"What headers do we need?","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Do we need all Accepted, Rejected, Pending targets?","type":"text"}]}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[250.25]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[19.51]},"content":[{"type":"paragraph","content":[{"text":"2","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[144.63]},"content":[{"type":"paragraph","content":[{"text":"dataType section needs to be confirmed.","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[271.48]},"content":[{"type":"paragraph","content":[{"type":"mention","attrs":{"id":"557058:0ed6b2ee-361d-48b6-a3d7-ed50a73d1945","text":"@kieran mccarthy"}},{"text":" to confirm for all the events.","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[250.25]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[19.51]},"content":[{"type":"paragraph","content":[{"text":"3","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[144.63]},"content":[{"type":"paragraph","content":[{"text":"Grouping of the response for rejected and pending to be finalized.","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[271.48]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[250.25]},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Overview","type":"text","marks":[{"type":"strong"}]}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"NCMP will receive the Subscription Request from DME in the form of an Event.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"NCMP will be responsible for the below operations. ( ","type":"text"},{"text":"Consumer Code for DME Event","type":"text","marks":[{"type":"strong"}]},{"text":" )","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Since NCMP already knows the structure of the incoming subscription request it will map the incoming request to java object.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Persist the request in the subscription-registry model which we already introduced.","type":"text"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"NCMP ( Producer Code and ","type":"text"},{"text":"Record the published time","type":"text","marks":[{"type":"strong"}]},{"text":" ) ","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Enrich the request with the additional properties and a proper ","type":"text"},{"text":"dmiRequestId ","type":"text","marks":[{"type":"strong"}]},{"text":"( subscriptionId+subscriptionName+dmiServiceName)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Save the dmiRequestId in the distributed map along with the current-time. ( we can call it published time ) . This will be useful at a later point in time.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Now forward the subscription request to the dmi-plugins based on the incoming target cmHandles we have. ( Since we have the information that which dmi-plugin is responsible for which cmHandle , we can figure this out ).","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"At this level we could have forwarded the event to multiple dedicated topics.","type":"text"}]}]}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"DMI-Plugin","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"It will have a consumer code to listen from a particular topic.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"It will translate the event so that it is able to extract the important information from the event.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"DMI-Plugin is responsible to talk to the underlying Nodes it is managing inorder to register the subscription ( i.e provide the predicate information ) ","type":"text"},{"text":"NOTE ","type":"text","marks":[{"type":"textColor","attrs":{"color":"#ff6600"}},{"type":"strong"}]},{"text":": ","type":"text"},{"text":"We will skip this part in the onap-dmi-plugin implementation.","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"DMI-Plugin will respond back with the response as ","type":"text"},{"text":"accepted ","type":"text","marks":[{"type":"strong"}]},{"text":"/ ","type":"text"},{"text":"rejected","type":"text","marks":[{"type":"strong"}]},{"text":". We will have a response format which will be discussed in the dedicated place.","type":"text"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"NCMP ( Consumer for DMI-Plugin Response ) ","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"We should continuously be checking if the published time has elapsed for that subscription response and we don't have to wait before sending the response back to the consumer. ( possibly we can discuss a solution using Hzaelcast TTL feature ) ","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":" The incoming message will have the dmiRequestId which we can match in the map and check if the timer condition is satisfied ( i.e if the message arrives before the configured time and there are other pending requests , then we wait)","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if we contact multiple dmi plugins and all respond back within time then we collect the response from all of them and send a collective response and we dont have to wait for pre-configured time.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if we contact multiple dmi plugins and none of them respond back within time then we respond as and when we recieve the response from them. ","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if we contact multiple dmi plugins and some of them respond back then we wait for preconfigured time and collect the response. We respond back with what we have till the cutoff time and then later when we receive the events we will send them through.","type":"text"}]}]}]}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Subscription Architecture Diagram","type":"text","marks":[{"type":"strong"}]}]},{"type":"extension","attrs":{"extensionType":"com.atlassian.confluence.macro.core","extensionKey":"drawio","parameters":{"macroParams":{"border":{"value":"true"},"":{"value":""},"diagramName":{"value":"Subscription Create Component Diagram"},"simpleViewer":{"value":"false"},"width":{"value":""},"links":{"value":"auto"},"tbstyle":{"value":"top"},"lbox":{"value":"true"},"diagramWidth":{"value":"651"},"revision":{"value":"1"}},"macroMetadata":{"macroId":{"value":"a07dfa9f-bbd9-414a-bc47-dac2c503d6a7"},"schemaVersion":{"value":"1"},"placeholder":[{"type":"image","data":{"url":"https://ac.draw.io/connectImage?border=true&=&diagramName=Subscription+Create+Component+Diagram&simpleViewer=false&width=&links=auto&tbstyle=top&lbox=true&diagramWidth=651&revision=1"}}],"title":"draw.io Diagram"}}}},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Subscription Create Sequence Diagram","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"extension","attrs":{"extensionType":"com.atlassian.confluence.macro.core","extensionKey":"plantuml","parameters":{"macroParams":{"title":{"value":"Subscription Create"},"__bodyContent":{"value":"@startuml \"Subsciption Create\"\n\nactor rApp as \"rApp/Client\"\nparticipant DME\nparticipant NCMP\nparticipant DMI_PLUGIN\n\nrApp -> DME\nDME -> NCMP: 1. Incoming subscriptionCreate event\nNCMP -> NCMP: 2. NCMP to persist incoming subscription request.\nNCMP -> DMI_PLUGIN: 3. ncmp to forward event to relevant dmi plugin\nDMI_PLUGIN -> DMI_PLUGIN: 4. Apply the requested event and respond with the status\nDMI_PLUGIN --> NCMP: 5. Status of the subscriptionCreate request whether accepted/rejected/pending\nNCMP --> DME: 6. Respond with the status(rejected/pending) that we received from dmi plugin\nDME --> rApp\n\n@enduml"},"atlassian-macro-output-type":{"value":"INLINE"}},"macroMetadata":{"macroId":{"value":"59250454-6b14-4e2f-84fb-557cade216cf"},"schemaVersion":{"value":"1"},"title":"plantuml"}}}},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"DME to NCMP","type":"text","marks":[{"type":"strong"}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Subscription Create Event (Schema 1)","type":"text","marks":[{"type":"strong"}]}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Subscription Create Event (Schema 1) ","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"shell"},"content":[{"text":"topic subscription\n\nid generated by client\nsource \"SCO-9989752\"\nspecversion \"1.0\"\ntype subscriptionCreated\ntime\ndataschema org.onap.ncmp.cm.subscription:1.0.0\n\n{\n \"data\": {\n \"subscription\": {\n \"clientID\": \"SCO-9989752\",\n \"name\": \"cm-subscription-001\"\n },\n \"dataType\": {\n \"dataspace\": \"ALL\",\n \"dataCategory\": \"CM\",\n \"dataProvider\": \"CM-SERVICE\"\n },\n \"predicates\": {\n “targets” : [“cmHandle1”, “cmHandle2”, “cmHandle3”] # cmhandle targets\n \"datastore\": “passthrough-operational\",\n \"datastore-xpath-filter\": \"//_3gpp-nr-nrm-gnbdufunction:GNBDUFunction/ \n _3gpp-nr-nrm-nrcelldu:NRCellDU/ | //_3gpp-nr-nrm-gnbcuupfunction:GNBCUUPFunction// |\n //_3gpp-nr-nrm-gnbcucpfunction:GNBCUCPFunction/_3gpp-nr-nrm-nrcelldu:NRCellCU// |\n //_3gpp-nr-nrm-nrsectorcarrier:NRSectorCarrier//” \n \n }\n}\n\n\"javaType\": \"org.onap.cps.ncmp.events.avcsubscription1_0_0.client_to_ncmp\"","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"NCMP saves in CPS","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Persisted Subscription Information (Schema 2)","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"plaintext"},"content":[{"text":"{\n\t\"clientID\": \"SCO-9989752\",\n \"subscriptionName\": \"cm-subscription-001\"\n\t\"isTagged\" : \"true\" #optional\n\t\"predicates\": {\n\t\t\"targetCmHandles\":[\n\t\t\t{\"cmHandleId\":\"cmHandle1\", \"status\":\"pending\"},\n\t\t\t{\"cmHandleId\":\"cmHandle2\", \"status\":\"pending\"},\n\t\t\t{\"cmHandleId\":\"cmHandle3\", \"status\":\"pending\"}\n\t\t]\n\t\t\"datastore\":\"passthrough-operational\"\n\t}\n\t\n}","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"NCMP to ","type":"text","marks":[{"type":"strong"}]},{"text":"DMI-Plugins","type":"text","marks":[{"type":"strong"}]}]},{"type":"mediaSingle","attrs":{"layout":"align-start","width":55.0},"content":[{"type":"media","attrs":{"width":1280,"id":"9b95ef34-1801-4644-ab83-318df1abaed9","collection":"contentId-16517944","type":"file","height":720}}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Input Schema (Schema 3) - Produced by NCMP and Consumed by DMI Plugins","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"plaintext"},"content":[{"text":"topic: ncmp-dmi-cm-avc-subscription-dminame1\n\nid uuid\nsource \"SCO-9989752\"\nspecversion \"1.0\"\ntype subscriptionCreated\ntime // ncmp will generate\ndataschema org.onap.ncmp.dmi.cm.subscription:1.0.0\ndata\n\n{\n\"data\":{\n \"subscription\":{\n \"clientID\":\"SCO-9989752\",\n \"name\":\"cm-subscription-001\",\n \"isTagged\":false\n },\n \"dataType\":{\n \"dataspace\":\"ALL\",\n \"dataCategory\":\"CM\",\n \"dataProvider\":\"CM-SERVICE\"\n },\n \"predicates\":{\n \"targets\":[ \n\t\t\t{\"id\" : ,\n \"additional-properties\": [\"shape\":\"circle\"]}, \n {\"id\" : ,\n \"additional-properties\": [\"shape\":\"triangle\"]}, \n {\"id\" : ,\n \"additional-properties\": [\"shape\":\"square\"]}\n ],\n \"datastore\":\"passthrough-running\",\n \"datastore-xpath-filter\":\"//_3gpp-nr-nrm-gnbdufunction:GNBDUFunction/_3gpp-nr-nrm-nrcelldu:NRCellDU/ | //_3gpp-nr-nrm-gnbcuupfunction:GNBCUUPFunction// | //_3gpp-nr-nrm-gnbcucpfunction:GNBCUCPFunction/_3gpp-nr-nrm-nrcelldu:NRCellCU// | //_3gpp-nr-nrm-nrsectorcarrier:NRSectorCarrier//\"\n }\n }\n}\n\n\"javaType\": \"org.onap.cps.ncmp.events.avcsubscription1_0_0.ncmp_to_dmi\"","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"DMI-Plugins to NCMP","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Output Schema (Schema 4) - Produced by DMI Plugins","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"plaintext"},"content":[{"text":"topic: dmi-ncmp-cm-avc-subscription\n\nid uuid - generated by dmi-plugins\nsource \nspecversion \"1.0\"\ntype subscriptionCreatedStatus\ntime - generated by dmi\ncorrelationid: :\ndataschema org.onap.ncmp.dmi.cm.subscription:1.0.0\ndata\n{\n \"clientId\":\"SCO-9989752\",\n \"subscriptionName\":\"cm-subscription-001\",\n \"dmiName\":\"\",\n \"subscriptionStatus\":[\n { \n \t\tid : , \n \t\tstatus : rejected / accepted ,\n \t\tdetails : // only present for rejected \n\t},\n {...}\n ]\n}\n\n\"javaType\": \"org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp\"","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Notes","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"dmiName in Output Schema is populated from application.yml of DMI-plugin.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"DMI-plugin subscribes to the topic to consume Input Schema given in application.yml of DMI-plugin.","type":"text"}]}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"application.yml of DMI-Plugin","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"plaintext"},"content":[{"text":"\tdmi:\n\t\tservice:\n\t\t\tname: ${DMI_SERVICE_NAME:ncmp-dmi-plugin}\n\tapp:\n\t\tdmi:\n\t\t\tavc:\n\t\t\t\tsubscription-topic: ${DMI_CM_AVC_SUBSCRIPTION:ncmp-dmi-cm-avc-subscription-${dmi.service.name}}\n\n","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"NCMP to Client-Apps","type":"text","marks":[{"type":"strong"}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Proposed outcome (Schema 5)","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"plaintext"},"content":[{"text":"topic: subscription-response\n\nid uuid - generated by NCMP\nsource \nspecversion \"1.0\"\ntype subscriptionCreatedStatus\ntime // NCMP would generate\ncorrelationid: clientId:subscriptionName\ndataschema org.onap.ncmp.cm.subscription:1.0.0\ndata\n\n{\n \"data\": {\n “statusCode” : 207, # Some error code reflecting partial success. ** // To be discussed with the whole team\n “statusMessage” : “Partially Applied Subscription”,\n “additionalInfo” : {\n “rejected” : [{\n “details” : “faulty subscription format for target(s)”, // need to finalize the detailed message for grouping.\n “targets” : [“cmhandle1”, “cmhandle2”, “cmhandle3”]\n },\n\t\t\t{\n “details” : “faulty subscription format for target(s) - xyz”, // need to finalize the detailed message for grouping.\n “targets” : [“cmhandle1”]\n }\n],\n “pending” : {\n “details” : “EMS/node connectivity issues, retrying”,\n “targets” : [“cmhandle4”, “cmhandle5”, “cmhandle6”]\n }\n }\n}\n\n// we dont have to send the accepted cmhandle details.\n \n** 202 could indicate complete failure – \n \"data\": {\n “statusCode” : 406, # Some error code reflecting complete rejection of the request\n “statusMessage” : “Subscription rejected : Faulty Subscription Data”,\n “additionalInfo” : {\n “rejected” : {\n “details” : “//NRxxCellDU is not a valid subscription type”\n },\n\nHave another for Pending CMHandles gone to accepted\n\n\"javaType\": \"org.onap.cps.ncmp.events.avcsubscription1_0_0.ncmp_to_client\"","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Implementation proposal of DMI Response Timeout","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"text":"Given that a Subscription Create Event has been received by the NCMP and that NCMP is going to forward that subscription to multiple DMI Plugins.","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The NCMP will create a new thread which will wait 30 seconds.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The NCMP will add an entry to a hazelcast Map> with the clientID and subscriptionName combined as a key and the DMI Plugin names which the subscription has been forwarded to","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Every time a DMI responds to NCMP, NCMP persists the response. The Map entry is for the subscription is then checked","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if the subscription entry still exists in the Map, the NCMP removes the DMI Plugin name from the Set of the relevant Map entry.","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if the Set is now empty, NCMP removes the Map entry and compiles & send a full outcome response","type":"text"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if the subscription entry does not exists in the Map, the NCMP compiles & sends a partial outcome response","type":"text"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"If the Wait thread completes the 30s countdown,","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if the map entry for the subscription exists in the map the thread removes the map entry from the Map. It then sends a partial outcome response","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"if the map entry for the subscription does not exist in the map, the thread does nothing","type":"text"}]}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Cloud Event Subscription Event","type":"text","marks":[{"type":"strong"}]}]},{"type":"extension","attrs":{"extensionType":"com.atlassian.confluence.macro.core","extensionKey":"excerpt-include","parameters":{"macroParams":{"":{"value":"CPS Events Structure"}},"macroMetadata":{"macroId":{"value":"45d32a87-b0eb-425a-bfa9-d73b897b494b"},"schemaVersion":{"value":"1"},"title":"Insert excerpt"}}}},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]}],"version":1}