Code Review / ccsdk / cds.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: ba75d2f) | patch
Message Prioritization message group lock. 82/99982/1
authorBrinda Santh <bs2796@att.com>
Thu, 2 Jan 2020 16:59:29 +0000 (11:59 -0500)
committerBrinda Santh <bs2796@att.com>
Thu, 2 Jan 2020 16:59:29 +0000 (11:59 -0500)
commit4f4e2de08d3c6259da2497950a96d549d3e82f8a
tree4c5a8e7a97d96e9de73ecb7ed1b53597ee0ebdd5tree | snapshot
parentba75d2fad2b0111a510f4ee4cc87e658fb32ac4bcommit | diff
Message Prioritization message group lock.

Implementation to avoid concurrent procession of message group while prioritization.

Sample message prioritization Kafka listener properties.

Issue-ID: CCSDK-2011
Signed-off-by: Brinda Santh <bs2796@att.com>
Change-Id: Ifbf39985b03c662b6ccf7740be711cfeb7bfbebb
ms/blueprintsprocessor/application/src/main/resources/application-dev.properties diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/README.md [moved from ms/blueprintsprocessor/functions/message-prioritizaion/README.txt with 90% similarity] diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/pom.xml diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/AbstractMessagePrioritizeProcessor.kt diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/MessagePrioritizationConsumer.kt diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessagePrioritizeProcessor.kt diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/utils/MessageProcessorUtils.kt diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/MessagePrioritizationConsumerTest.kt diff | blob | history
ms/blueprintsprocessor/functions/message-prioritizaion/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/TestConfiguration.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/atomix-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/atomix/service/AtomixBluePrintClusterService.kt diff | blob | history
ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/service/BluePrintClusterService.kt diff | blob | history
Controller Design Studio (design-time tool : evolution of appc/cdt)