diff options
author | pkaras <piotr.karas@nokia.com> | 2019-06-05 08:32:20 +0200 |
---|---|---|
committer | pkaras <piotr.karas@nokia.com> | 2019-06-05 08:32:20 +0200 |
commit | 411cb435b5878b2663bfa9b6d2495c707353cd63 (patch) | |
tree | 4064657157e496514bb9ef2b23c4dbabda8a56ce /src/main/java/org | |
parent | e01dcd3ea03b02294d4b0f3cd46e825499ec4d49 (diff) |
Aaf cleanup in TopicService implementation
Change-Id: Ica0ed712223f246a6134c03ca12f3de05a3e01ff
Issue-ID: DMAAP-1217
Signed-off-by: piotr.karas <piotr.karas@nokia.com>
Diffstat (limited to 'src/main/java/org')
-rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/service/AafTopicSetupService.java | 4 | ||||
-rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/service/TopicService.java | 9 |
2 files changed, 11 insertions, 2 deletions
diff --git a/src/main/java/org/onap/dmaap/dbcapi/service/AafTopicSetupService.java b/src/main/java/org/onap/dmaap/dbcapi/service/AafTopicSetupService.java index 031f594..a1fc89e 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/service/AafTopicSetupService.java +++ b/src/main/java/org/onap/dmaap/dbcapi/service/AafTopicSetupService.java @@ -77,6 +77,10 @@ class AafTopicSetupService extends BaseLoggingClass { return okStatus(); } + ApiError aafTopicCleanup(Topic topic) { + return okStatus(); + } + private String getTopicsNsRoot() throws TopicSetupException { String nsr = dmaapService.getDmaap().getTopicNsRoot(); if (nsr == null) { diff --git a/src/main/java/org/onap/dmaap/dbcapi/service/TopicService.java b/src/main/java/org/onap/dmaap/dbcapi/service/TopicService.java index 3386b97..2065754 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/service/TopicService.java +++ b/src/main/java/org/onap/dmaap/dbcapi/service/TopicService.java @@ -246,11 +246,16 @@ public class TopicService extends BaseLoggingClass { apiError.setFields("fqtn"); return null; } + + ApiError topicSetupError = aafTopicSetupService.aafTopicCleanup(topic); + updateApiError(apiError, topicSetupError); + if (apiError.getCode() >= 400) { + return null; + } + ArrayList<MR_Client> clients = new ArrayList<MR_Client>(clientService.getAllMrClients(pubId)); for (Iterator<MR_Client> it = clients.iterator(); it.hasNext(); ) { MR_Client c = it.next(); - - clientService.removeMr_Client(c.getMrClientId(), false, apiError); if (!apiError.is2xx()) { return null; |