diff options
2 files changed, 3 insertions, 3 deletions
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 69eadab26a..8027e69d56 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 @@ -65,7 +65,7 @@ public class DmiSubJobRequestHandler { dataJobMetadata.dataContentType(), dataJobId, dmi3ggpWriteOperations); final String dmiResourceUrl = getDmiResourceUrl(dataJobId, producerKey); - final ResponseEntity<Object> responseEntity = dmiRestClient.postOperationWithJsonData( + final ResponseEntity<Object> responseEntity = dmiRestClient.synchronousPostOperationWithJsonData( RequiredDmiService.DATA, dmiResourceUrl, jsonObjectMapper.asJsonString(subJobWriteRequest), @@ -82,4 +82,4 @@ public class DmiSubJobRequestHandler { return DmiServiceUrlBuilder.newInstance().pathSegment("writeJob").variablePathSegment("requestId", dataJobId) .build(producerKey.dmiServiceName(), dmiProperties.getDmiBasePath()); } -}
\ No newline at end of file +} diff --git a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/DmiSubJobRequestHandlerSpec.groovy b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/DmiSubJobRequestHandlerSpec.groovy index a1e0329792..8dc3d223b6 100644 --- a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/DmiSubJobRequestHandlerSpec.groovy +++ b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/DmiSubJobRequestHandlerSpec.groovy @@ -33,7 +33,7 @@ class DmiSubJobRequestHandlerSpec extends Specification { when: 'sending request to DMI invoked' objectUnderTest.sendRequestsToDmi(dataJobId, dataJobMetadata, dmiWriteOperationsPerProducerKey) then: 'the dmi rest client is called' - 1 * mockDmiRestClient.postOperationWithJsonData(RequiredDmiService.DATA, _, _, OperationType.CREATE, NO_AUTH) >> response + 1 * mockDmiRestClient.synchronousPostOperationWithJsonData(RequiredDmiService.DATA, _, _, OperationType.CREATE, NO_AUTH) >> response and: 'the result contains the expected sub-job write responses' def result = response.body assert result.subJobId() == 'my-sub-job-id' |