diff options
| author |   sourabh_sourabh <sourabh.sourabh@est.tech> | 2023-02-03 16:20:58 +0000 |
|---|---|---|
| committer | Sourabh Sourabh <sourabh.sourabh@est.tech> | 2023-02-09 09:45:31 +0000 |
| commit | 4e30a658e44f957748e89394bc6a394fb460feaa (patch) | |
| tree | 317daf45d8e416c83408c6d1cf43acc21d6cc737 /cps-ncmp-service/src/main/java | |
| parent | ef200d43e3d2dc2be292bd76a8963cbb711247e7 (diff) | |
Produce subscription create event for subscription-topic: cm-avc-subscription
- Groovy Kafka (component level) : Produce subscription create event.
Issue-ID: CPS-1394
Signed-off-by: sourabh_sourabh <sourabh.sourabh@est.tech>
Change-Id: Ib020c0a4458406925792fc074afd998aa09af158
Signed-off-by: sourabh_sourabh <sourabh.sourabh@est.tech>
Diffstat (limited to 'cps-ncmp-service/src/main/java')
| -rw-r--r-- | cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/event/avc/SubscriptionEventConsumer.java | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/event/avc/SubscriptionEventConsumer.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/event/avc/SubscriptionEventConsumer.java index 1f0324693a..92949cbb79 100644 --- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/event/avc/SubscriptionEventConsumer.java +++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/event/avc/SubscriptionEventConsumer.java @@ -1,6 +1,6 @@ /* * ============LICENSE_START======================================================= - * Copyright (C) 2022 Nordix Foundation + * Copyright (C) 2022-2023 Nordix Foundation * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -37,10 +37,11 @@ public class SubscriptionEventConsumer { * * @param subscriptionEvent the event to be consumed */ - @KafkaListener(topics = "${app.ncmp.avc.subscription-topic}") + @KafkaListener(topics = "${app.ncmp.avc.subscription-topic}", + properties = {"spring.json.value.default.type=org.onap.cps.ncmp.event.model.SubscriptionEvent"}) public void consumeSubscriptionEvent(final SubscriptionEvent subscriptionEvent) { if ("CM".equals(subscriptionEvent.getEvent().getDataType().getDataCategory())) { - log.debug("Consuming event {} ...", subscriptionEvent.toString()); + log.debug("Consuming event {} ...", subscriptionEvent); if ("CREATE".equals(subscriptionEvent.getEventType().value())) { log.info("Subscription for ClientID {} with name{} ...", subscriptionEvent.getEvent().getSubscription().getClientID(), |