Formatting Code base with ktlint

[ccsdk/cds.git] / ms / blueprintsprocessor / functions / message-prioritizaion / src / main / kotlin / org / onap / ccsdk / cds / blueprintsprocessor / functions / message / prioritization / topology / MessagePrioritizationPunctuators.kt

diff --git a/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessagePrioritizationPunctuators.kt b/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessagePrioritizationPunctuators.kt
index a745e03..5435ebe 100644 (file)
--- a/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessagePrioritizationPunctuators.kt
+++ b/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessagePrioritizationPunctuators.kt
@@ -24,41 +24,46 @@ import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.s
 import org.onap.ccsdk.cds.blueprintsprocessor.message.kafka.AbstractBluePrintMessagePunctuator
 import org.onap.ccsdk.cds.controllerblueprints.core.logger
 
-
-class MessagePriorityExpiryPunctuator(private val messagePrioritizationStateService: MessagePrioritizationStateService)
-    : AbstractBluePrintMessagePunctuator() {
+class MessagePriorityExpiryPunctuator(private val messagePrioritizationStateService: MessagePrioritizationStateService) :
+    AbstractBluePrintMessagePunctuator() {
 
     private val log = logger(MessagePriorityExpiryPunctuator::class)
     lateinit var configuration: PrioritizationConfiguration
 
     override suspend fun punctuateNB(timestamp: Long) {
 
-        log.info("**** executing expiry punctuator applicationId(${processorContext.applicationId()}), " +
-                "taskId(${processorContext.taskId()})")
+        log.info(
+            "**** executing expiry punctuator applicationId(${processorContext.applicationId()}), " +
+                    "taskId(${processorContext.taskId()})"
+        )
         val expiryConfiguration = configuration.expiryConfiguration
         val fetchMessages = messagePrioritizationStateService
-                .getExpiryEligibleMessages(expiryConfiguration.maxPollRecord)
+            .getExpiryEligibleMessages(expiryConfiguration.maxPollRecord)
 
         val expiredIds = fetchMessages?.map { it.id }
         if (expiredIds != null && expiredIds.isNotEmpty()) {
             messagePrioritizationStateService.updateMessagesState(expiredIds, MessageState.EXPIRED.name)
             fetchMessages.forEach { expired ->
-                processorContext.forward(expired.id, expired,
-                        To.child(MessagePrioritizationConstants.SINK_EXPIRED))
+                processorContext.forward(
+                    expired.id, expired,
+                    To.child(MessagePrioritizationConstants.SINK_EXPIRED)
+                )
             }
         }
     }
 }
 
-class MessagePriorityCleanPunctuator(private val messagePrioritizationStateService: MessagePrioritizationStateService)
-    : AbstractBluePrintMessagePunctuator() {
+class MessagePriorityCleanPunctuator(private val messagePrioritizationStateService: MessagePrioritizationStateService) :
+    AbstractBluePrintMessagePunctuator() {
 
     private val log = logger(MessagePriorityCleanPunctuator::class)
     lateinit var configuration: PrioritizationConfiguration
 
     override suspend fun punctuateNB(timestamp: Long) {
-        log.info("**** executing clean punctuator applicationId(${processorContext.applicationId()}), " +
-                "taskId(${processorContext.taskId()})")
-        //TODO
+        log.info(
+            "**** executing clean punctuator applicationId(${processorContext.applicationId()}), " +
+                    "taskId(${processorContext.taskId()})"
+        )
+        // TODO
     }
-}
\ No newline at end of file
+}