diff options
author | 2020-05-11 14:38:01 -0400 | |
---|---|---|
committer | 2020-05-11 14:43:56 -0400 | |
commit | 1f3bc0ca592a7f4245b0f70bfdcf63222dbf6106 (patch) | |
tree | bbc3591875bbf38613b5477bec66ff5271a6d60d /ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test | |
parent | 16ced660a671dea28fa56ffa860651d78ebb4501 (diff) |
Kafka Audit Service : CorrelationUUID from request is not matching the correct response in Kafka
Moved out CorrelationUUID linking between the request and the response from the Kafka Audit Service to the ExecutionServiceHandler.
This prevents the race condition happening when several ExecutionServiceOutputs try to set the CorrelationUUID related to their ExecutionServiceInput.
Issue-ID: CCSDK-2370
Signed-off-by: Julien Fontaine <julien.fontaine@bell.ca>
Change-Id: I0c5934d4486961fbfcb34fd2d2492cd843350025
Diffstat (limited to 'ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test')
-rw-r--r-- | ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/ExecutionServiceHandlerTest.kt | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/ExecutionServiceHandlerTest.kt b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/ExecutionServiceHandlerTest.kt index 37f7861be..191456296 100644 --- a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/ExecutionServiceHandlerTest.kt +++ b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/ExecutionServiceHandlerTest.kt @@ -114,7 +114,7 @@ class ExecutionServiceHandlerTest { } verify { - publishAuditService.publish(executionServiceOutput!!) + publishAuditService.publish(executionServiceInput.correlationUUID, executionServiceOutput!!) } } } |