Revert "Renaming Files having BluePrint to have Blueprint"

[ccsdk/cds.git] / ms / blueprintsprocessor / modules / inbounds / selfservice-api / src / main / kotlin / org / onap / ccsdk / cds / blueprintsprocessor / selfservice / api / BluePrintProcessingKafkaConsumer.kt

diff --git a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BluePrintProcessingKafkaConsumer.kt
similarity index 92%
rename from ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt
rename to ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BluePrintProcessingKafkaConsumer.kt
index 82fd78e..ed9b4d5 100644 (file)
--- a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt
+++ b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BluePrintProcessingKafkaConsumer.kt
@@ -24,10 +24,10 @@ import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput
 import org.onap.ccsdk.cds.blueprintsprocessor.message.BlueprintMessageMetricConstants
-import org.onap.ccsdk.cds.blueprintsprocessor.message.service.BlueprintMessageLibPropertyService
+import org.onap.ccsdk.cds.blueprintsprocessor.message.service.BluePrintMessageLibPropertyService
 import org.onap.ccsdk.cds.blueprintsprocessor.message.service.BlueprintMessageConsumerService
 import org.onap.ccsdk.cds.blueprintsprocessor.message.utils.BlueprintMessageUtils
-import org.onap.ccsdk.cds.controllerblueprints.core.BlueprintProcessorException
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException
 import org.onap.ccsdk.cds.controllerblueprints.core.jsonAsType
 import org.onap.ccsdk.cds.controllerblueprints.core.logger
 import org.onap.ccsdk.cds.controllerblueprints.core.updateErrorMessage
@@ -45,13 +45,13 @@ import javax.annotation.PreDestroy
     havingValue = "true"
 )
 @Service
-open class BlueprintProcessingKafkaConsumer(
-    private val blueprintMessageLibPropertyService: BlueprintMessageLibPropertyService,
+open class BluePrintProcessingKafkaConsumer(
+    private val blueprintMessageLibPropertyService: BluePrintMessageLibPropertyService,
     private val executionServiceHandler: ExecutionServiceHandler,
     private val meterRegistry: MeterRegistry
 ) {
 
-    val log = logger(BlueprintProcessingKafkaConsumer::class)
+    val log = logger(BluePrintProcessingKafkaConsumer::class)
 
     private val ph = Phaser(1)
 
@@ -75,28 +75,28 @@ open class BlueprintProcessingKafkaConsumer(
             blueprintMessageConsumerService = try {
                 blueprintMessageLibPropertyService
                     .blueprintMessageConsumerService(CONSUMER_SELECTOR)
-            } catch (e: BlueprintProcessorException) {
+            } catch (e: BluePrintProcessorException) {
                 val errorMsg = "Failed creating Kafka consumer message service."
                 throw e.updateErrorMessage(
                     SelfServiceApiDomains.SELF_SERVICE_API, errorMsg,
                     "Wrong Kafka selector provided or internal error in Kafka service."
                 )
             } catch (e: Exception) {
-                throw BlueprintProcessorException("failed to create consumer service ${e.message}")
+                throw BluePrintProcessorException("failed to create consumer service ${e.message}")
             }
 
             /** Get the Message Producer Service **/
             val blueprintMessageProducerService = try {
                 blueprintMessageLibPropertyService
                     .blueprintMessageProducerService(PRODUCER_SELECTOR)
-            } catch (e: BlueprintProcessorException) {
+            } catch (e: BluePrintProcessorException) {
                 val errorMsg = "Failed creating Kafka producer message service."
                 throw e.updateErrorMessage(
                     SelfServiceApiDomains.SELF_SERVICE_API, errorMsg,
                     "Wrong Kafka selector provided or internal error in Kafka service."
                 )
             } catch (e: Exception) {
-                throw BlueprintProcessorException("failed to create producer service ${e.message}")
+                throw BluePrintProcessorException("failed to create producer service ${e.message}")
             }
 
             launch {