From: KAPIL SINGAL <ks220y@att.com>
Date: Mon, 10 Aug 2020 11:30:27 +0000 (+0000)
Subject: Merge "Make use of Kafka Key for Audit service and Kafka listener"
X-Git-Tag: 1.0.0~64
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=6bd8ce3a79f4caefa0b810a71285d96edb389da4;p=ccsdk%2Fcds.git

Merge "Make use of Kafka Key for Audit service and Kafka listener"
---

6bd8ce3a79f4caefa0b810a71285d96edb389da4
diff --cc ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
index 12cadfa66,93885bfa2..145c37b01
--- a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
+++ b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
@@@ -106,11 -93,11 +106,11 @@@ class KafkaPublishAuditService
          val key = executionServiceOutput.actionIdentifiers.blueprintName
          try {
              this.outputInstance = this.getOutputInstance(OUTPUT_SELECTOR)
-             this.outputInstance!!.sendMessage(executionServiceOutput)
+             this.outputInstance!!.sendMessage(key, executionServiceOutput)
          } catch (e: Exception) {
              var errMsg =
 -                if (e.message != null) "ERROR : $e"
 -                else "ERROR : Failed to send execution request to Kafka."
 +                    if (e.message != null) "ERROR : $e"
 +                    else "ERROR : Failed to send execution request to Kafka."
              log.error(errMsg)
          }
      }