Code Review / ccsdk / cds.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 7f858b0) | patch
Assign a unique worker ID for CDS Kafka worker 31/118831/7
authorJulien Fontaine <julien.fontaine@bell.ca>
Mon, 15 Feb 2021 23:31:24 +0000 (18:31 -0500)
committerKAPIL SINGAL <ks220y@att.com>
Tue, 16 Mar 2021 19:17:05 +0000 (19:17 +0000)
commitae588292c67e20c5cae8cb3c899957aac79a676d
treefe14757bc84ca95a38ed7d82a2cb9db6b5825c5ftree | snapshot
parent7f858b082287017c2f28b7fac03476c5f761a517commit | diff
Assign a unique worker ID for CDS Kafka worker

* Modified CDS Kafka workers to add the 5 lasts characters of the env var HOSTNAME to their worker ID.
* Small refactoring to move some utilitary functions to BlueprintMessageUtils

Issue-ID: CCSDK-3204
Signed-off-by: Julien Fontaine <julien.fontaine@bell.ca>
Change-Id: Iaacd35e9cbe4705d17548518040c679185eaf30a
ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BlueprintMessageLibData.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/KafkaMessageProducerService.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/utils/BlueprintMessageUtils.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/BlueprintMessageConsumerServiceTest.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/BlueprintMessageProducerServiceTest.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/utils/BlueprintMessageUtilsTest.kt diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt diff | blob | history
Controller Design Studio (design-time tool : evolution of appc/cdt)