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 91%
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 c4de907..440490a 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
@@ -21,9 +21,9 @@ import kotlinx.coroutines.channels.consumeEach
 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.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.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
@@ -41,12 +41,12 @@ 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
 ) {
 
-    val log = logger(BluePrintProcessingKafkaConsumer::class)
+    val log = logger(BlueprintProcessingKafkaConsumer::class)
 
     private val ph = Phaser(1)
 
@@ -70,28 +70,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 {