The current implementation of DCAE SliceAnalysis (post https://gerrit.onap.org/r/c/dcaegen2/services/+/127369)  includes different dmaap client library (cambria and dmaapClient from Dmaap project) which are un-supported.

This Jira is to tracking migration to reactive streams using DCAE SDK dmaap-client library.

Here is a list of changes in in sliceAnalysis-ms subproject, in order to transfer dmaap calling to DCAE SDK dmaap-client

  1）DmaapClient.java：from（CambriaConsumer）to（MessageRouterSubscriber）

  2）NotificationConsumer.java：refactoring to using（MessageRouterSubscriber）

  3）NotificationProducer.java：refactoring to using（MessageRouterPublisher）

  4）DmaapUtils.java：refactoring to using（MessageRouterSubscriber，MessageRouterPublisher）

  5）MRTopicMonitor.java：refactoring from（MRConsumerImpl），to（MessageRouterSubscriber），also the adaptor inside

  6）PolicyDmaapClient.java：refactoring to using（MessageRouterPublisher）