Revert "Renaming Files having BluePrint to have Blueprint"

[ccsdk/cds.git] / ms / blueprintsprocessor / functions / message-prioritization / src / main / kotlin / org / onap / ccsdk / cds / blueprintsprocessor / functions / message / prioritization / kafka / KafkaMessagePrioritizationConsumer.kt

diff --git a/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/kafka/KafkaMessagePrioritizationConsumer.kt b/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/kafka/KafkaMessagePrioritizationConsumer.kt
index ecdcbff..4ab399f 100644 (file)
--- a/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/kafka/KafkaMessagePrioritizationConsumer.kt
+++ b/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/kafka/KafkaMessagePrioritizationConsumer.kt
@@ -24,15 +24,15 @@ import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.P
 import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.utils.MessageProcessorUtils.bluePrintProcessorSupplier
 import org.onap.ccsdk.cds.blueprintsprocessor.message.KafkaStreamsBasicAuthConsumerProperties
 import org.onap.ccsdk.cds.blueprintsprocessor.message.MessageConsumerProperties
-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.service.KafkaStreamConsumerFunction
-import org.onap.ccsdk.cds.controllerblueprints.core.BlueprintProcessorException
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException
 import org.onap.ccsdk.cds.controllerblueprints.core.logger
 import org.onap.ccsdk.cds.controllerblueprints.core.splitCommaAsList
 
 open class KafkaMessagePrioritizationConsumer(
-    private val bluePrintMessageLibPropertyService: BlueprintMessageLibPropertyService,
+    private val bluePrintMessageLibPropertyService: BluePrintMessageLibPropertyService,
     private val kafkaMessagePrioritizationService: MessagePrioritizationService
 ) {
 
@@ -50,7 +50,7 @@ open class KafkaMessagePrioritizationConsumer(
             return object : KafkaStreamConsumerFunction {
 
                 val kafkaConsumerConfiguration = prioritizationConfiguration.kafkaConfiguration
-                    ?: throw BlueprintProcessorException("failed to get kafka consumer configuration")
+                    ?: throw BluePrintProcessorException("failed to get kafka consumer configuration")
 
                 override suspend fun createTopology(
                     messageConsumerProperties: MessageConsumerProperties,
@@ -91,7 +91,7 @@ open class KafkaMessagePrioritizationConsumer(
     suspend fun startConsuming(prioritizationConfiguration: PrioritizationConfiguration) {
 
         val kafkaConsumerConfiguration = prioritizationConfiguration.kafkaConfiguration
-            ?: throw BlueprintProcessorException("failed to get kafka consumer configuration")
+            ?: throw BluePrintProcessorException("failed to get kafka consumer configuration")
 
         streamingConsumerService = consumerService(kafkaConsumerConfiguration.inputTopicSelector)