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 / MessageAggregateProcessor.kt

diff --git a/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessageAggregateProcessor.kt b/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessageAggregateProcessor.kt
index 45f5c77..3e697e6 100644 (file)
--- a/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessageAggregateProcessor.kt
+++ b/ms/blueprintsprocessor/functions/message-prioritizaion/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/message/prioritization/topology/MessageAggregateProcessor.kt
@@ -22,7 +22,6 @@ import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.M
 import org.onap.ccsdk.cds.blueprintsprocessor.functions.message.prioritization.MessageState
 import org.onap.ccsdk.cds.controllerblueprints.core.logger
 
-
 open class MessageAggregateProcessor : AbstractMessagePrioritizeProcessor<String, String>() {
 
     private val log = logger(MessageAggregateProcessor::class)
@@ -50,16 +49,21 @@ open class MessageAggregateProcessor : AbstractMessagePrioritizeProcessor<String
                     storeMessages.forEach { messagePrioritization ->
                         try {
                             /** Update the data store */
-                            messagePrioritizationStateService.setMessageStateANdError(messagePrioritization.id,
-                                    MessageState.ERROR.name, error)
+                            messagePrioritizationStateService.setMessageStateANdError(
+                                messagePrioritization.id,
+                                MessageState.ERROR.name, error
+                            )
                             /** Publish to Error topic */
-                            this.processorContext.forward(messagePrioritization.id, messagePrioritization,
-                                    To.child(MessagePrioritizationConstants.SINK_OUTPUT))
+                            this.processorContext.forward(
+                                messagePrioritization.id, messagePrioritization,
+                                To.child(MessagePrioritizationConstants.SINK_OUTPUT)
+                            )
                         } catch (sendException: Exception) {
-                            log.error("failed to update/publish error message(${messagePrioritization.id}) : " +
-                                    "${sendException.message}", e)
+                            log.error(
+                                "failed to update/publish error message(${messagePrioritization.id}) : " +
+                                        "${sendException.message}", e
+                            )
                         }
-
                     }
                 }
             }
@@ -73,4 +77,4 @@ open class MessageAggregateProcessor : AbstractMessagePrioritizeProcessor<String
             processorContext.forward(id, id, To.child(MessagePrioritizationConstants.PROCESSOR_OUTPUT))
         }
     }
-}
\ No newline at end of file
+}