summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorToine Siebelink <toine.siebelink@est.tech>2023-03-08 18:07:13 +0000
committerGerrit Code Review <gerrit@onap.org>2023-03-08 18:07:13 +0000
commitf8c4cb6e3be9af6d6395b03bfae4056b5af89a9d (patch)
tree0c2ecf76d4154904a941635ef0fade83c3426bba
parentd23fc75c8d3aa485da9e914e730a5583630126ec (diff)
parentf0d50b68c2696b41f1886e704145a1edfa343750 (diff)
Merge "[CPS] Add configurable params for topic"
-rw-r--r--cps-application/src/main/resources/application.yml3
-rw-r--r--cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java2
2 files changed, 4 insertions, 1 deletions
diff --git a/cps-application/src/main/resources/application.yml b/cps-application/src/main/resources/application.yml
index f7fe46e4e0..1d3f5013e2 100644
--- a/cps-application/src/main/resources/application.yml
+++ b/cps-application/src/main/resources/application.yml
@@ -102,6 +102,9 @@ app:
lcm:
events:
topic: ${LCM_EVENTS_TOPIC:ncmp-events}
+ dmi:
+ cm-events:
+ topic: ${DMI_CM_EVENTS_TOPIC:dmi-cm-events}
notification:
diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java
index 79a36bf506..58290a7e9d 100644
--- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java
+++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java
@@ -44,7 +44,7 @@ public class AvcEventConsumer {
* @param avcEvent the event to be consumed and produced.
*/
@KafkaListener(
- topics = "dmi-cm-events",
+ topics = "${app.dmi.cm-events.topic}",
properties = {"spring.json.value.default.type=org.onap.cps.ncmp.event.model.AvcEvent"})
public void consumeAndForward(final AvcEvent avcEvent) {
log.debug("Consuming AVC event {} ...", avcEvent);