From 5b2eb630483fc997beb191202c9dda85a11d96d1 Mon Sep 17 00:00:00 2001
From: leventecsanyi <levente.csanyi@est.tech>
Date: Wed, 17 Jul 2024 16:48:15 +0200
Subject: Fix dataProducerId in SubJobWriteRequest

Issue-ID: CPS-2322
Change-Id: I7bfdfd05ffacb085ac056707d477f348cb5bd64f
Signed-off-by: leventecsanyi <levente.csanyi@est.tech>
---
 .../java/org/onap/cps/ncmp/impl/datajobs/DmiSubJobRequestHandler.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'cps-ncmp-service/src/main')

diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/DmiSubJobRequestHandler.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/DmiSubJobRequestHandler.java
index 3d1c5237d6..1f9ea11d4f 100644
--- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/DmiSubJobRequestHandler.java
+++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/DmiSubJobRequestHandler.java
@@ -63,7 +63,7 @@ public class DmiSubJobRequestHandler {
         final List<SubJobWriteResponse> subJobWriteResponses = new ArrayList<>(dmiWriteOperationsPerProducerKey.size());
         dmiWriteOperationsPerProducerKey.forEach((producerKey, dmi3ggpWriteOperations) -> {
             final SubJobWriteRequest subJobWriteRequest = new SubJobWriteRequest(dataJobMetadata.dataAcceptType(),
-                    dataJobMetadata.dataContentType(), dataJobId, dmi3ggpWriteOperations);
+                    dataJobMetadata.dataContentType(), producerKey.dataProducerIdentifier(), dmi3ggpWriteOperations);
 
             final UrlTemplateParameters urlTemplateParameters = getUrlTemplateParameters(dataJobId, producerKey);
             final ResponseEntity<Object> responseEntity = dmiRestClient.synchronousPostOperationWithJsonData(
-- 
cgit 1.2.3-korg