Code Review / ccsdk / cds.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: a6fae85) | patch
Kafka Messaging Controller API. 01/88301/23
authorprathameshmo <prathamesh.morde@bell.ca>
Tue, 11 Jun 2019 21:47:42 +0000 (17:47 -0400)
committerprathameshmo <prathamesh.morde@bell.ca>
Tue, 25 Jun 2019 21:03:44 +0000 (17:03 -0400)
commitb134a815fbb3404e46551f8f2361e6cca6c7728d
tree1c2df5a0b010146dc5310b2e64f884fda1eea833tree | snapshot
parenta6fae85764a8dfbeba6000a060b8be0f21fb0466commit | diff
Kafka Messaging Controller API.

Things done-
Addressed review comments.
Logic to consume events and process it.
Added integration testing.

Change-Id: If574a363f9fb8581018cc5a7ba106251a9d8caf1
Issue-ID:CCSDK-1356
Signed-off-by: prathamesh morde <prathamesh.morde@bell.ca>
Signed-off-by: prathameshmo <prathamesh.morde@bell.ca>
17 files changed:
ms/blueprintsprocessor/application/src/main/java/org/onap/ccsdk/cds/blueprintsprocessor/BlueprintProcessorApplication.java diff | blob | history
ms/blueprintsprocessor/application/src/main/resources/application-dev.properties diff | blob | history
ms/blueprintsprocessor/application/src/main/resources/application.properties diff | blob | history
ms/blueprintsprocessor/application/src/test/java/org/onap/ccsdk/cds/blueprintsprocessor/BlueprintProcessorApplicationTest.java diff | blob | history
ms/blueprintsprocessor/application/src/test/resources/application.properties diff | blob | history
ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/KafkaBasicAuthMessageProducerService.kt diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/pom.xml diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/MessagingConfig.kt [new file with mode: 0644] blob
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/MessagingController.kt [new file with mode: 0644] blob
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BluePrintManagementGRPCHandlerTest.kt diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BluePrintProcessingGRPCHandlerTest.kt diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/ExecutionServiceHandlerTest.kt diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/messaginglib/MessagingControllerTest.kt [new file with mode: 0644] blob
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/messaginglib/ProducerConfiguration.kt [new file with mode: 0644] blob
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/resources/application-test.properties diff | blob | history
ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/test/resources/cba-for-kafka-integration.zip [new file with mode: 0644] blob
ms/blueprintsprocessor/parent/pom.xml diff | blob | history
Controller Design Studio (design-time tool : evolution of appc/cdt)