summaryrefslogtreecommitdiffstats
path: root/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy
diff options
context:
space:
mode:
authorseanbeirne <sean.beirne@est.tech>2023-07-25 16:54:03 +0100
committerSean Beirne <sean.beirne@est.tech>2023-07-26 09:53:34 +0000
commit5272927ea8fd21487d640e22e62c087913e302f5 (patch)
tree1a2c32f2e98f86ed0ee34ebd2bae2ede076c8448 /src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy
parentc0ebeaa0ddcb758874320097194dfd4aa8a947c4 (diff)
DMI to NCMP Subscription Delete Response
Issue-ID: CPS-1809 Signed-off-by: seanbeirne <sean.beirne@est.tech> Change-Id: I482cdea009dccc97aea5e96d5d831603c6e21206
Diffstat (limited to 'src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy')
-rw-r--r--src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy
index ba02f535..8382f67f 100644
--- a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy
+++ b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy
@@ -88,7 +88,7 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
def subscriptionEvent = objectMapper.readValue(jsonData, SubscriptionEvent.class)
objectUnderTest.cmAvcSubscriptionResponseTopic = testTopic
def cloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
- .withType("subscriptionCreated")
+ .withType(subscriptionType)
.withDataSchema(URI.create("urn:cps:" + SubscriptionEvent.class.getName() + ":1.0.0"))
.withExtension("correlationid", eventKey)
.withTime(OffsetDateTime.ofInstant(timestamp.toInstant(), ZoneId.of("UTC")))
@@ -98,6 +98,10 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
objectUnderTest.consumeSubscriptionEvent(testEventSent)
then: 'no exception is thrown'
noExceptionThrown()
+ where: 'given #senario'
+ scenario | subscriptionType
+ 'Subscription Create Event' | "subscriptionCreated"
+ 'Subscription Delete Event' | "subscriptionDeleted"
}
def 'Consume invalid message.'() {