core: log execution time when processing messages

Signed-off-by: Eloi Charpentier <eloi.charpentier.42@gmail.com>
OpenRailAssociation · Nov 21, 2024 · 0239b1e · 0239b1e
1 parent 6be0604
commit 0239b1e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt b/core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt
@@ -175,6 +175,7 @@ class WorkerCommand : CliCommand {
             val channel = connection.createChannel()
             val callback =
                 fun(message: Delivery) {
+                    val startTimeMS = System.currentTimeMillis()
                     reportActivity(activityChannel, "request-received")
 
                     val replyTo = message.properties.replyTo
@@ -281,7 +282,12 @@ class WorkerCommand : CliCommand {
                     }
 
                     channel.basicAck(message.envelope.deliveryTag, false)
-                    logger.info("request for path {} processed", path)
+                    val executionTimeMS = System.currentTimeMillis() - startTimeMS
+                    logger.info(
+                        "request for path {} processed in {}s",
+                        path,
+                        executionTimeMS / 1_000.0
+                    )
                 }
             channel.basicConsume(
                 WORKER_REQUESTS_QUEUE,