{"type":"doc","content":[{"type":"extension","attrs":{"extensionType":"com.atlassian.confluence.macro.core","extensionKey":"toc","parameters":{"macroParams":{},"macroMetadata":{"macroId":{"value":"621a4397-c017-426f-bfad-e59f17f192b0"},"schemaVersion":{"value":"1"},"title":"Table of Contents"}}}},{"type":"heading","attrs":{"level":2},"content":[{"text":"References","type":"text"}]},{"type":"paragraph","content":[{"type":"inlineCard","attrs":{"url":"https://lf-onap.atlassian.net/browse/CPS-1392"}}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Steps","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Consume Event","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Check if dataCategory is 'CM'","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"log consumption","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Check scheme","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Create object","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Log object","type":"text"}]}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"extension","attrs":{"extensionType":"com.atlassian.confluence.macro.core","extensionKey":"drawio","parameters":{"macroParams":{"border":{"value":"true"},"":{"value":""},"diagramName":{"value":"Untitled Diagram"},"simpleViewer":{"value":"false"},"width":{"value":""},"links":{"value":"auto"},"tbstyle":{"value":"top"},"lbox":{"value":"true"},"diagramWidth":{"value":"511"},"revision":{"value":"1"}},"macroMetadata":{"macroId":{"value":"7ca69e07-f6c2-4012-82cb-653400a93e8a"},"schemaVersion":{"value":"1"},"placeholder":[{"type":"image","data":{"url":"https://ac.draw.io/connectImage?border=true&=&diagramName=Untitled+Diagram&simpleViewer=false&width=&links=auto&tbstyle=top&lbox=true&diagramWidth=511&revision=1"}}],"title":"draw.io Diagram"}}}},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"paragraph","content":[{"text":"Consumer Pseudo Code","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Pseudo Code","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"public class SubscriptionCreatedEventConsumer {\n\t\n \t@KafkaListener(topics = \"${app.ncmp.cm-avc-subscription.topic}\")\t//Blocking: See issue #2\n\tpublic void consumeSubscriptionEvent(final SubscriptionCreatedEvent subscriptionCreatedEvent){\n\t\tif(subscriptionCreatedEvent.dataCategory == 'CM'){\t\t\t\t//Check dataCategory\n\t\t\tlog.debug(\"Consuming event {} ...\", subscriptionCreatedEvent);\n\t\t\tif(checkFormat(subscriptionCreatedEvent)){\t\t\t\t\t//Check format of message\n\t\t\t\tSubscription createSubscription = new Subscription()\t//Create Object\n\t\t\t\tlog.debug(\"subscription created \"+ createSubscription)\t//Log subscription\n\t\t\t}\n\t\t}\n\t}\n\n \tpublic boolean checkFormat(SubscriptionCreatedEvent event){\n\t\t//Blocking: See issue #1\n\t}\n}\n\n","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"paragraph","content":[{"text":"Subscription Object - Will be finalised when schema confirmed","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Object Parameters","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"String clientID\nStirng name\nString subscriptionID = clientID+name\nBoolean isTagged = default no\n\nString dataspace\nString dataCategory\t= necessary? should always be 'CM'\nString dataProvidor\nString schemeName\nString schemaVersion\n\nCollection persistence","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Issues & Decisions","type":"text"}]},{"type":"table","attrs":{"isNumberColumnEnabled":true},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Issue","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Notes ","type":"text"}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Decision","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"background":"#fffae6","rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Subscription Event Scheme","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"background":"#fffae6","rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Protocol","type":"text","marks":[{"type":"strong"}]},{"text":" ","type":"text","marks":[{"type":"textColor","attrs":{"color":"#172b4d"}}]},{"text":": Kafka Event","type":"text","marks":[{"type":"textColor","attrs":{"color":"#172b4d"}}]},{"type":"hardBreak"},{"text":"Topic","type":"text","marks":[{"type":"strong"}]},{"text":" ","type":"text","marks":[{"type":"strong"}]},{"text":": variable topic name","type":"text","marks":[{"type":"textColor","attrs":{"color":"#172b4d"}}]}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Event Scheme","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"{\n \"version\": \"\",\n \"eventType\": \"subscriptionCreated\",\n \"event\": {\n \"subscription\": {\n \"clientID\": \"\",\n \"name\": \"\",\n \"isTagged\": \", optional parameter, default is no\"\n },\n \"dataType\": {\n \"dataspace\": \"\",\n \"dataCategory\": \"\",\n \"dataProvider\": \"\"\n \"schemaName\": \"\"\n \"schemaVersion\": \"\"\n },\n \"predicates\": {\n \"\": \"\",\n \"param2\": [\n \"value21\",\n \"value22\"\n ]\n }\n }\n}","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]}]},{"type":"tableCell","attrs":{"colspan":1,"background":"#fffae6","rowspan":1},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"background":"#fffae6","rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Configurable Topic","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"background":"#fffae6","rowspan":1},"content":[{"type":"paragraph","content":[{"text":"Pointer where previously implemented","type":"text"}]}]},{"type":"tableCell","attrs":{"colspan":1,"background":"#fffae6","rowspan":1},"content":[{"type":"paragraph","content":[{"type":"hardBreak"}]}]}]}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]}],"version":1}

Browser not supported