summaryrefslogtreecommitdiffstats
path: root/cps-ncmp-service/src/main/java/org
diff options
context:
space:
mode:
authorsourabh_sourabh <sourabh.sourabh@est.tech>2023-02-03 16:20:58 +0000
committerSourabh Sourabh <sourabh.sourabh@est.tech>2023-02-09 09:45:31 +0000
commit4e30a658e44f957748e89394bc6a394fb460feaa (patch)
tree317daf45d8e416c83408c6d1cf43acc21d6cc737 /cps-ncmp-service/src/main/java/org
parentef200d43e3d2dc2be292bd76a8963cbb711247e7 (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/org')
-rw-r--r--cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/event/avc/SubscriptionEventConsumer.java7
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(),