diff options
author | 2023-08-21 15:52:52 +0100 | |
---|---|---|
committer | 2023-08-21 15:52:52 +0100 | |
commit | 9f819f06747f48ad3d2c01021d820f2f4ac73b53 (patch) | |
tree | af7cb5d6793ef3de10cce4cbd92e31ceb34af319 /cps-ncmp-service/src/main | |
parent | 9f8ddd047943525bebf8a49599f22dbe530b4361 (diff) |
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 <sourabh.sourabh@est.tech>
Change-Id: I30738b90d2ff0d14b5ee0bac680eff834aa968bf
Diffstat (limited to 'cps-ncmp-service/src/main')
-rw-r--r-- | cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumer.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumer.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumer.java index 9649b0109..0bc18076c 100644 --- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumer.java +++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumer.java @@ -56,8 +56,8 @@ public class DataOperationEventConsumer { log.info("Consuming event payload {} ...", dataOperationEventConsumerRecord.value()); final String eventTarget = KafkaHeaders.getParsedKafkaHeader( dataOperationEventConsumerRecord.headers(), "ce_destination"); - final String eventId = KafkaHeaders.getParsedKafkaHeader( - dataOperationEventConsumerRecord.headers(), "ce_id"); - eventsPublisher.publishCloudEvent(eventTarget, eventId, dataOperationEventConsumerRecord.value()); + final String correlationId = KafkaHeaders.getParsedKafkaHeader( + dataOperationEventConsumerRecord.headers(), "ce_correlationid"); + eventsPublisher.publishCloudEvent(eventTarget, correlationId, dataOperationEventConsumerRecord.value()); } } |