summaryrefslogtreecommitdiffstats
path: root/src/main/java/org
diff options
context:
space:
mode:
authorsu622b <su622b@att.com>2019-08-08 08:21:55 -0400
committersu622b <su622b@att.com>2019-08-08 08:29:43 -0400
commit0cb3bb0b0c99a70dd31995a7dc4d06b53f6e43d0 (patch)
tree5ac2e5d69a54e23e968c3c8eb04ee8e55daeaa25 /src/main/java/org
parent1748f08023b63a266f533a9490a044536950e9ec (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/java/org')
-rw-r--r--src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java4
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);