From 9f819f06747f48ad3d2c01021d820f2f4ac73b53 Mon Sep 17 00:00:00 2001 From: sourabh_sourabh Date: Mon, 21 Aug 2023 15:52:52 +0100 Subject: Replace event-id with correlation-id for data read operation cloud event - Modified data operation event consumer to send correlation-id instead if event-id while publishing cloud event to client topic. Issue-ID: CPS-1842 Signed-off-by: sourabh_sourabh Change-Id: I30738b90d2ff0d14b5ee0bac680eff834aa968bf --- .../onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'cps-ncmp-service/src/test') diff --git a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy index 14ecd9282..f24ff6253 100644 --- a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy +++ b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy @@ -68,7 +68,7 @@ class SerializationIntegrationSpec extends ConsumerBaseSpec { and: 'wait a little for async processing of message' TimeUnit.MILLISECONDS.sleep(300) then: 'the event has been forwarded' - 1 * mockEventsPublisher.publishCloudEvent('some client topic', 'my-event-id', _) >> { args -> { capturedForwardedEvent = args[2] } } + 1 * mockEventsPublisher.publishCloudEvent('some client topic', 'some-correlation-id', _) >> { args -> { capturedForwardedEvent = args[2] } } and: 'the forwarded event is identical to the event that was sent' assert capturedForwardedEvent == cloudEvent } @@ -94,6 +94,7 @@ class SerializationIntegrationSpec extends ConsumerBaseSpec { .withType('DataOperationEvent') .withSource(URI.create('some-source')) .withExtension('destination','some client topic') + .withExtension('correlationid','some-correlation-id') .withData(objectMapper.writeValueAsBytes(dataOperationEvent)) .build() } -- cgit 1.2.3-korg