From cc7b12386f6ada2cabead94da33cf3ed68ac8cf7 Mon Sep 17 00:00:00 2001 From: Julien Fontaine Date: Wed, 23 Jun 2021 08:44:00 -0400 Subject: Add Request ID and Sub Request ID to CDS kafka logs Improved log message when a message is published or consumed by CDS Kafka to specify the RequestID and SubRequestID. Issue-ID: CCSDK-3348 Signed-off-by: Julien Fontaine Change-Id: I50e068d9aa36df8fe4ee5f0f6a8e9bd7a1209467 --- .../core/api/data/BlueprintProcessorData.kt | 20 ++++++++------------ 1 file changed, 8 insertions(+), 12 deletions(-) (limited to 'ms/blueprintsprocessor/modules/commons/processor-core') diff --git a/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/api/data/BlueprintProcessorData.kt b/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/api/data/BlueprintProcessorData.kt index 924aed898..8009bbb8a 100644 --- a/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/api/data/BlueprintProcessorData.kt +++ b/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/api/data/BlueprintProcessorData.kt @@ -33,16 +33,18 @@ import java.util.UUID * DATE : 8/15/2018 */ -open class ExecutionServiceInput { - - @get:ApiModelProperty(required = false, hidden = true) - var correlationUUID: String = UUID.randomUUID().toString() - +abstract class CommonExecutionServiceData { @get:ApiModelProperty(required = true, value = "Headers providing request context.") lateinit var commonHeader: CommonHeader @get:ApiModelProperty(required = true, value = "Provide information about the action to execute.") lateinit var actionIdentifiers: ActionIdentifiers +} + +open class ExecutionServiceInput : CommonExecutionServiceData() { + + @get:ApiModelProperty(required = false, hidden = true) + var correlationUUID: String = UUID.randomUUID().toString() @get:ApiModelProperty( required = true, @@ -57,17 +59,11 @@ open class ExecutionServiceInput { var stepData: StepData? = null } -open class ExecutionServiceOutput { +open class ExecutionServiceOutput : CommonExecutionServiceData() { @get:ApiModelProperty(required = false, hidden = true) var correlationUUID: String? = null - @get:ApiModelProperty(required = true, value = "Headers providing request context.") - lateinit var commonHeader: CommonHeader - - @get:ApiModelProperty(required = true, value = "Provide information about the action to execute.") - lateinit var actionIdentifiers: ActionIdentifiers - @get:ApiModelProperty(required = true, value = "Status of the request.") lateinit var status: Status -- cgit 1.2.3-korg