X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=ms%2Fblueprintsprocessor%2Ffunctions%2Fmessage-prioritization%2Fsrc%2Fmain%2Fkotlin%2Forg%2Fonap%2Fccsdk%2Fcds%2Fblueprintsprocessor%2Ffunctions%2Fmessage%2Fprioritization%2Futils%2FMessageProcessorUtils.kt;h=86cec36978b40e02d7ee5b16579a16ee6618cc91;hb=45263f50896a7021cd17d78ce83b29365cb19c29;hp=3eba4ed86325e5cc012ba0dfe8ac0f9e3b677c5d;hpb=76cb04c2302c9f8f0395f86d8e8d246fdae0fd28;p=ccsdk%2Fcds.git

diff --git a/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/utils/MessageProcessorUtils.kt b/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/utils/MessageProcessorUtils.kt
index 3eba4ed86..86cec3697 100644
--- a/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/utils/MessageProcessorUtils.kt
+++ b/ms/blueprintsprocessor/functions/message-prioritization/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/utils/MessageProcessorUtils.kt
@@ -22,14 +22,14 @@ import org.onap.ccsdk.cds.blueprintsprocessor.core.service.ClusterLock
 import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.db.MessagePrioritization
 import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.kafka.AbstractMessagePrioritizeProcessor
 import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.toFormatedCorrelation
-import org.onap.ccsdk.cds.controllerblueprints.core.BlueprintProcessorException
-import org.onap.ccsdk.cds.controllerblueprints.core.service.BlueprintDependencyService
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintDependencyService
 
 object MessageProcessorUtils {
 
     /** Utility to create the cluster lock for message [messagePrioritization] prioritization procssing.*/
     suspend fun prioritizationGrouplock(messagePrioritization: MessagePrioritization): ClusterLock? {
-        val clusterService = BlueprintDependencyService.optionalClusterService()
+        val clusterService = BluePrintDependencyService.optionalClusterService()
 
         return if (clusterService != null && clusterService.clusterJoined() &&
             !messagePrioritization.correlationId.isNullOrBlank()
@@ -39,31 +39,31 @@ object MessageProcessorUtils {
             val lockName = "prioritize::${messagePrioritization.group}::$correlationId"
             val clusterLock = clusterService.clusterLock(lockName)
             clusterLock.lock()
-            if (!clusterLock.isLocked()) throw BlueprintProcessorException("failed to lock($lockName)")
+            if (!clusterLock.isLocked()) throw BluePrintProcessorException("failed to lock($lockName)")
             clusterLock
         } else null
     }
 
     /** Utility to create the cluster lock for expiry scheduler*/
     suspend fun prioritizationExpiryLock(): ClusterLock? {
-        val clusterService = BlueprintDependencyService.optionalClusterService()
+        val clusterService = BluePrintDependencyService.optionalClusterService()
         return if (clusterService != null && clusterService.clusterJoined()) {
             val lockName = "prioritize-expiry"
             val clusterLock = clusterService.clusterLock(lockName)
             clusterLock.lock()
-            if (!clusterLock.isLocked()) throw BlueprintProcessorException("failed to lock($lockName)")
+            if (!clusterLock.isLocked()) throw BluePrintProcessorException("failed to lock($lockName)")
             clusterLock
         } else null
     }
 
     /** Utility to create the cluster lock for expiry scheduler*/
     suspend fun prioritizationCleanLock(): ClusterLock? {
-        val clusterService = BlueprintDependencyService.optionalClusterService()
+        val clusterService = BluePrintDependencyService.optionalClusterService()
         return if (clusterService != null && clusterService.clusterJoined()) {
             val lockName = "prioritize-clean"
             val clusterLock = clusterService.clusterLock(lockName)
             clusterLock.lock()
-            if (!clusterLock.isLocked()) throw BlueprintProcessorException("failed to lock($lockName)")
+            if (!clusterLock.isLocked()) throw BluePrintProcessorException("failed to lock($lockName)")
             clusterLock
         } else null
     }
@@ -80,7 +80,7 @@ object MessageProcessorUtils {
     fun <K, V> bluePrintProcessorSupplier(name: String): ProcessorSupplier<K, V> {
         return ProcessorSupplier<K, V> {
             // Dynamically resolve the Prioritization Processor
-            BlueprintDependencyService.instance<AbstractMessagePrioritizeProcessor<K, V>>(name)
+            BluePrintDependencyService.instance<AbstractMessagePrioritizeProcessor<K, V>>(name)
         }
     }
 }