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),
return DmiServiceUrlBuilder.newInstance().pathSegment("writeJob").variablePathSegment("requestId", dataJobId)
.build(producerKey.dmiServiceName(), dmiProperties.getDmiBasePath());
}
-}
\ No newline at end of file
+}
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'