diff options
author | 2019-08-08 08:21:55 -0400 | |
---|---|---|
committer | 2019-08-08 08:29:43 -0400 | |
commit | 0cb3bb0b0c99a70dd31995a7dc4d06b53f6e43d0 (patch) | |
tree | 5ac2e5d69a54e23e968c3c8eb04ee8e55daeaa25 /src/main | |
parent | 1748f08023b63a266f533a9490a044536950e9ec (diff) |
revert topic exist topic check while publishing
Issue-ID: DMAAP-1247
Change-Id: Ie0d50a2cecbb0c0cb26305adfb52ac65b1c8c032
Signed-off-by: su622b <su622b@att.com>
Diffstat (limited to 'src/main')
-rw-r--r-- | src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java b/src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java index ec5bfc0..f3b7e54 100644 --- a/src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java +++ b/src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java @@ -324,9 +324,7 @@ public class EventsServiceImpl implements EventsService { validateIpBlacklist(errRespProvider, ctx); final Topic metaTopic = ctx.getConfigReader().getfMetaBroker().getTopic(topic); - if (metaTopic == null) { - throw new CambriaApiException(errRespProvider.getTopicNotFoundError()); - } + final boolean isAAFTopic = authorizeClientWhenNeeded(ctx, metaTopic, topic, errRespProvider, PUBLISH_ACTION); |