Please provide a hyperlink to the repo of the component identified, the Topic/Feed name (if applicable) and the client type (publisher/subscriber).
| Message Router | Topic Name | Client Type (PUB/SUB) | Client specific Code base |
|---|---|---|---|
| CPS - CPS-Core* | To be decided | PUB | |
| CPS - DMI-Plugin* | To be Confirmed (existing A&AI DMaaP eventchannel) | SUB | |
| CPS - CPS* Temporal | To be decided (same as CPS-Core PUB above) | SUB | |
| DCAE - PNF registration Handler | org.onap.dmaap.mr.PNF_READY | PUB | Multiple DMaaP Classes under / prh-app-server / src / main / java / org / onap / dcaegen2 / services / prh / Most if not all consuming the dcaegen2 sdk dmaap client Also, a model Class here |
| DCAE - PNF registration Handler | unauthenticated.VES_PNFREG_OUTPUT | SUB | |
| DCAE - PNF registration Handler | unauthenticated.PNF_UPDATE | PUB | |
| DCAE - Restconf collector | unauthenticated.DCAE_RCC_OUTPUT | PUB | Custom client code - here Not using the dcae dmaap sdk! Using ATT Cambria artifact as part of MR interaction which is only available as a mvn artifact - here |
| DCAE - SNMP trap collector | unauthenticated.ONAP-COLLECTOR-SNMPTRAP | PUB | Custom python client - here |
| DCAE - SON handler | unauthenticated.VES_MEASUREMENT_OUTPUT | SUB | DMaaP Utils class - here Entity class - here Custom clients - here Using ATT Cambria artifact as part of MR interaction which is only available as a mvn artifact - here |
| DCAE - SON handler | unauthenticated.SEC_FAULT_OUTPUT | SUB | |
| DCAE - SON handler | PCI-NOTIF-TOPIC-NGHBR-LIST-CHANGE-INFO | SUB | |
| DCAE - SON handler | DCAE_CL_RSP | SUB | |
| DCAE - SON handler | unauthenticated.DCAE_CL_OUTPUT | PUB | |
| DCAE - Ves Collector | org.onap.dmaap.mr.PNF_REGISTRATION | PUB | Custom clients - here possibly more elsewhere! Using ATT Cambria artifact as part of MR interaction which is only available as a mvn artifact - here |
| DCAE - Ves Collector | unauthenticated.SEC_OTHER_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.SEC_HEARTBEAT_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.SEC_FAULT_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.VES_MEASUREMENT_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.VES_NOTIFICATION_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.VES_PNFREG_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.SEC_3GPP_PROVISIONING_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT | PUB | |
| DCAE - Ves Collector | unauthenticated.SEC_3GPP_PERFORMANCEASSURANCE_OUTPUT | PUB | |
| DCAE - PM Mapper | org.onap.dmaap.mr.PERFORMANCE_MEASUREMENTS | PUB | Most if not all consuming the dcaegen2 sdk dmaap client |
| DCAE - DataFileCollector | unauthenticated.VES_NOTIFICATION_OUTPUT | SUB | Custom client - here Consuming the dcaegen2 sdk dmaap client for subscribing Metadata class - here |
| DCAE - Heartbeat mS | unauthenticated.SEC_HEARTBEAT_OUTPUT | SUB | Custom python client - here Not sure this project is still using MR! |
| DCAE - Heartbeat mS | unauthenticated.DCAE_CL_OUTPUT | PUB | |
| DCAE - PM Subscription Handler | unauthenticated.DCAE_CL_OUTPUT | PUB | Custom python client - here |
| DCAE - PM Subscription Handler | unauthenticated.PMSH_CL_INPUT | SUB | |
| DCAE - PM Subscription Handler | AAI-EVENT | SUB | |
| DCAE - BBS Events processor | unauthenticated.PNF_UPDATE | SUB | Consuming the dcaegen2 sdk dmaap client for subscribing |
| DCAE - BBS Events processor | unauthenticated.CPE_AUTHENTICATION | SUB | |
| DCAE - BBS Events processor | unauthenticated.DCAE_CL_OUTPUT | PUB | |
| DCAE - KPI computation mS | org.onap.dmaap.mr.PERFORMANCE_MEASUREMENTS | SUB | Custom clients - here DMaaP utils class - here Using ATT Cambria artifact as part of MR interaction which is only available as a mvn artifact - here |
| DCAE - KPI computation mS | unauthenticated.DCAE_KPI_OUTPUT | PUB | |
| DCAE - Holmes Engine | unauthenticated.DCAE_CL_OUTPUT | PUB | Custom clients - here Could be more! |
| DCAE - Holmes Engine | unauthenticated.SEC_FAULT_OUTPUT | SUB | |
| DCAE - Slice Analysis mS | org.onap.dmaap.mr.PERFORMANCE_MEASUREMENTS | SUB | Custom clients - here Using ATT Cambria artifact as part of MR interaction which is only available as a mvn artifact - here |
| DCAE - Slice Analysis mS | unauthenticated.ML_RESPONSE_TOPIC | SUB | |
| DCAE - Slice Analysis mS | DCAE_CL_RSP | SUB | |
| DCAE - Slice Analysis mS | unauthenticated.DCAE_CL_OUTPUT | PUB | |
| DCAE - TCS gen2 mS | unauthenticated.VES_MEASUREMENT_OUTPUT | SUB | Multiple custom DMaaP classes - here |
| DCAE - TCS gen2 mS | unauthenticated.DCAE_CL_OUTPUT | PUB | |
| DCAE - VES Mapper mS | unauthenticated.DCAE_RCC_OUTPUT | SUB | A LOT of custom MR code - here |
| DCAE - VES Mapper mS | unauthenticated.ONAP-COLLECTOR-SNMPTRAP | SUB | |
| DCAE - VES Mapper mS | unauthenticated.SEC_FAULT_OUTPUT | PUB | |
| DCAE - VES Mapper mS | unauthenticated.VES_MEASUREMENT_OUTPUT | ? | |
| DCAE - VES Mapper mS | unauthenticated.VES_NOTIFICATION_OUTPUT | ? | |
| DCAE - VES Mapper mS | unauthenticated.VES_PNFREG_OUTPUT | PUB | |
| Policy - PAP-PDP | POLICY-PDP-PAP | PUB/SUB | Lots of MR stuff - here |
| Policy - PAP | POLICY-NOTIFICATION | PUB | |
| Policy - Drools Applications | DCAE_CL_RSP | PUB | |
| Policy - Drools Applications | SDNR-CL | PUB | |
| Policy - Drools Applications | SDNR-CL-RSP | SUB | |
| Policy - Drools Applications | DCAE_TOPIC | SUB | |
| Policy - Drools Applications | POLICY-CL-MGT | PUB | |
| SDC - Distribution client | SDC-DISTR-STATUS-TOPIC-AUTO | PUB | |
| SDC - Distribution client | SDC-DISTR-NOTIF-TOPIC-AUTO | PUB | |
*Note These components are aiming to use DMaaP in Istanbul release but are not using it yet.
| Bus Controller | Feed/Topic Name | Client Type |
|---|---|---|
| DCAE - DataFileCollector | bulk_pm_feed | PUB |
| DCAE - PM Mapper | bulk_pm_feed | SUB |
| Data Router | Feed Name | Client Type (PUB/SUB) |
|---|---|---|
| DCAE - DataFileCollector | bulk_pm_feed | PUB |
| DCAE - PM Mapper | bulk_pm_feed | SUB |
| dmaapClient | ||
|---|---|---|