summaryrefslogtreecommitdiffstats
path: root/cps-ncmp-service/src/main/java/org
diff options
context:
space:
mode:
authorToine Siebelink <toine.siebelink@est.tech>2023-02-09 14:38:50 +0000
committerGerrit Code Review <gerrit@onap.org>2023-02-09 14:38:50 +0000
commitdb90c8758d43b1daab09c760a3fe3102d772d7df (patch)
tree367c7d71026cb5596d5e361874fc67e2f89f036d /cps-ncmp-service/src/main/java/org
parenta230fafadb6bf262abc6d77eae327a16181330e4 (diff)
parent4e30a658e44f957748e89394bc6a394fb460feaa (diff)
Merge "Produce subscription create event for subscription-topic: cm-avc-subscription"
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(),