summaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumer.java3
-rw-r--r--src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapper.java3
2 files changed, 5 insertions, 1 deletions
diff --git a/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumer.java b/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumer.java
index d7622fae..bef68a67 100644
--- a/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumer.java
+++ b/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumer.java
@@ -65,6 +65,9 @@ public class SubscriptionEventConsumer {
if ("subscriptionCreated".equals(subscriptionType)) {
sendSubscriptionResponseMessage(eventKey, "subscriptionCreatedStatus",
formSubscriptionEventResponse(subscriptionEvent));
+ } else if ("subscriptionDeleted".equals(subscriptionType)) {
+ sendSubscriptionResponseMessage(eventKey, "subscriptionDeletedStatus",
+ formSubscriptionEventResponse(subscriptionEvent));
}
}
}
diff --git a/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapper.java b/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapper.java
index d7609932..49bdfe31 100644
--- a/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapper.java
+++ b/src/main/java/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapper.java
@@ -75,7 +75,8 @@ public class SubscriptionEventResponseMapper {
final String subscriptionType,
final String dmiName) {
try {
- return CloudEventBuilder.v1().withId(UUID.randomUUID().toString())
+ return CloudEventBuilder.v1()
+ .withId(UUID.randomUUID().toString())
.withSource(URI.create(dmiName))
.withType(subscriptionType)
.withDataSchema(URI.create("urn:cps:" + SubscriptionEventResponse.class.getName() + ":1.0.0"))